JXTA

Uses of Class
net.jxta.endpoint.Message

Packages that use Message
net.jxta.endpoint Provides interfaces and classes used for the addressing, filtering, sending, and receiving of messages within JXTA. 
net.jxta.pipe Pipes are the core mechanism for exchanging messages between JXTA applications or services. 
net.jxta.rendezvous The RendezVous Service is responsible for propagating messages within a JXTA PeerGroup. 
net.jxta.socket The socket package provides interface ala Socket over JXTA pipes. 
net.jxta.util A collection of utility classes used by the JXTA implementation and/or useful to users of the JXTA API. 
 

Uses of Message in net.jxta.endpoint
 

Methods in net.jxta.endpoint that return Message
 Message Message.clone()
          

Duplicates the Message.

 Message MessageFilterListener.filterMessage(Message message, EndpointAddress srcAddr, EndpointAddress dstAddr)
          This method is invoked by the EndpointService for each message for which this filter is registered.
static Message WireFormatMessageFactory.fromBuffer(ByteBuffer buffer, MimeMediaType type, MimeMediaType contentEncoding)
          Constructs an instance of Message from matching the type specified by the type parameter.
 Message WireFormatMessageFactory.Instantiator.fromBuffer(ByteBuffer buffer, MimeMediaType type, MimeMediaType contentEncoding)
          Create an abstract message from a serialization.
static Message WireFormatMessageFactory.fromWire(InputStream is, MimeMediaType type, MimeMediaType contentEncoding)
          Constructs an instance of Message from matching the type specified by the type parameter.
 Message WireFormatMessageFactory.Instantiator.fromWire(InputStream is, MimeMediaType type, MimeMediaType contentEncoding)
          Create an abstract message from a serialization.
 

Methods in net.jxta.endpoint with parameters of type Message
 void EndpointService.demux(Message msg)
          Deprecated. Please convert your code to use the EndpointListener.processIncomingMessage(Message,EndpointAddress,EndpointAddress) method instead. The addressing method used by demux() was never part of the formal JXTA protocol specification but was a defacto part because demux() depended upon it.
 Message MessageFilterListener.filterMessage(Message message, EndpointAddress srcAddr, EndpointAddress dstAddr)
          This method is invoked by the EndpointService for each message for which this filter is registered.
 void EndpointListener.processIncomingMessage(Message message, EndpointAddress srcAddr, EndpointAddress dstAddr)
          This method is invoked by the EndpointService for each incoming message which is addressed to this listener.
 void EndpointService.propagate(Message message, String serviceName, String serviceParam)
          Propagates (broadcasts) a message via all available Message Transports.
 void EndpointService.propagate(Message message, String serviceName, String serviceParam, int initialTTL)
          Propagates (broadcasts) a message via all available Message Transports.
 boolean MessagePropagater.propagate(Message msg, String serviceName, String serviceParams, int initialTTL)
          Propagates a Message via this Message Transport.
 boolean Messenger.sendMessage(Message msg)
          Sends a message to the destination specified at construction as if by invoking sendMessage(msg, null, null)
 boolean AbstractMessenger.sendMessage(Message msg)
          Sends a message to the destination specified at construction as if by invoking sendMessage(msg, null, null)
 boolean Messenger.sendMessage(Message msg, String service, String serviceParam)
          Sends a message to the destination specified at construction.
 boolean AbstractMessenger.sendMessage(Message msg, String rService, String rServiceParam)
          Sends a message to the destination specified at construction.
 void ChannelMessenger.sendMessage(Message msg, String service, String serviceParam, OutgoingMessageEventListener listener)
          Sends a message to the destination specified at construction.
 void Messenger.sendMessage(Message msg, String service, String serviceParam, OutgoingMessageEventListener listener)
          Sends a message to the destination specified at construction.
 void AbstractMessenger.sendMessage(Message msg, String service, String serviceParam, OutgoingMessageEventListener listener)
          Sends a message to the destination specified at construction.
 void Messenger.sendMessageB(Message msg, String service, String serviceParam)
          Simple sending: blocks until the message was accepted for sending or the messenger is not Messenger.USABLE; whichever occurs first.
 void AsyncChannelMessenger.sendMessageB(Message msg, String rService, String rServiceParam)
          Simple sending: blocks until the message was accepted for sending or the messenger is not Messenger.USABLE; whichever occurs first.
 void ThreadedMessenger.sendMessageB(Message msg, String service, String serviceParam)
          Simple sending: blocks until the message was accepted for sending or the messenger is not Messenger.USABLE; whichever occurs first.
protected abstract  void ThreadedMessenger.sendMessageBImpl(Message msg, String service, String param)
          Send a message blocking as needed until the message is sent.
 boolean Messenger.sendMessageN(Message msg, String service, String serviceParam)
          Sends a message to the destination specified at construction.
 boolean AsyncChannelMessenger.sendMessageN(Message msg, String rService, String rServiceParam)
          Sends a message to the destination specified at construction.
 boolean ThreadedMessenger.sendMessageN(Message msg, String service, String serviceParam)
          Sends a message to the destination specified at construction.
static WireFormatMessage WireFormatMessageFactory.toWire(Message msg, MimeMediaType type, MimeMediaType[] preferedEncodings)
          Constructs an instance of WireFormatMessage matching the type specified by the type parameter.
 WireFormatMessage WireFormatMessageFactory.Instantiator.toWire(Message msg, MimeMediaType type, MimeMediaType[] preferedContentEncoding)
          Create a WireFormatMessage from an abstract message.
 boolean ListenerAdaptor.watchMessage(OutgoingMessageEventListener listener, Message message)
          Select the given message and invoke the given listener when the message sending is complete.
 

Constructors in net.jxta.endpoint with parameters of type Message
OutgoingMessageEvent(Message source)
          Create an Outgoing Message Event.
OutgoingMessageEvent(Message source, Throwable failure)
          Create an Outgoing Message Event.
 

Uses of Message in net.jxta.pipe
 

Methods in net.jxta.pipe that return Message
 Message PipeMsgEvent.getMessage()
          Returns the message associated with the event
 Message InputPipe.poll(int timeout)
          Poll for a message from the pipe.
 Message InputPipe.waitForMessage()
          Wait (block) for a message to be received.
 

Methods in net.jxta.pipe with parameters of type Message
 boolean OutputPipe.send(Message msg)
          Send a message through the pipe

WARNING: The message object used when sending a pipe message should not be reused or modified after the OutputPipe.send(Message) call is made.

 

Constructors in net.jxta.pipe with parameters of type Message
PipeMsgEvent(Object source, Message message, PipeID pipeID)
          Creates a new event
 

Uses of Message in net.jxta.rendezvous
 

Methods in net.jxta.rendezvous with parameters of type Message
 void RendezVousService.propagate(Enumeration<? extends ID> destPeerIds, Message msg, String serviceName, String serviceParam, int ttl)
          Propagates a message to the specified peers.
 void RendezVousService.propagate(Message msg, String serviceName, String serviceParam, int ttl)
          Propagates a message to the local network and to as many members of the peer group as possible.
 void RendezVousService.propagateInGroup(Message msg, String serviceName, String serviceParam, int ttl)
          Propagates a message to as many members of the peer group as possible.
 void RendezVousService.propagateToNeighbors(Message msg, String serviceName, String serviceParam, int ttl)
          Propagates a message to members of the peer group reachable via the local network.
 void RendezVousService.walk(Message msg, String serviceName, String serviceParam, int ttl)
          Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message.
 void RendezVousService.walk(Vector<? extends ID> destPeerIDs, Message msg, String serviceName, String serviceParam, int ttl)
          

Walk a message through the rendezvous peers of the network: only rendezvous peers will receive the message.

 

Uses of Message in net.jxta.socket
 

Fields in net.jxta.socket declared as Message
protected static Message JxtaServerSocket.QUEUE_END_MESSAGE
          QUEUE_END_MESSAGE is used to signal that the queue has been closed.
 

Fields in net.jxta.socket with type parameters of type Message
protected  BlockingQueue<Message> JxtaServerSocket.queue
           
 

Methods in net.jxta.socket that return Message
protected  Message JxtaSocket.createConnectMessage(PeerGroup group, PipeAdvertisement pipeAdv, Credential credential, boolean isReliable, boolean initiator)
          Create a connection request/response message
 

Uses of Message in net.jxta.util
 

Methods in net.jxta.util that return Message
protected  Message JxtaBiDiPipe.createOpenMessage(PeerGroup group, PipeAdvertisement pipeAd)
          Creates a connection request message
 Message JxtaBiDiPipe.getMessage(int timeout)
          Gets a message from the queue.
 

Methods in net.jxta.util with parameters of type Message
static void MessageUtilities.addBoolean(Message message, String tagName, boolean value)
          Deprecated.  
static void MessageUtilities.addDouble(Message message, String tagName, double value)
          Deprecated.  
static void MessageUtilities.addInt(Message message, String tagName, int value)
          Deprecated.  
static void MessageUtilities.addLong(Message message, String tagName, long value)
          Deprecated.  
static void MessageUtilities.addString(Message message, String tagName, String value)
          Deprecated.  
static boolean MessageUtilities.getBoolean(Message message, String tagName, boolean defaultValue)
          Deprecated.  
static double MessageUtilities.getDouble(Message message, String tagName, double defaultValue)
          Deprecated.  
static int MessageUtilities.getInt(Message message, String tagName, int defaultValue)
          Deprecated.  
static long MessageUtilities.getLong(Message message, String tagName, long defaultValue)
          Deprecated.  
static String MessageUtilities.getString(Message message, String tagName, String defaultValue)
          Deprecated.  
 void JxtaBiDiPipe.processIncomingMessage(Message message)
          This method is invoked by the Reliablity library for each incoming data message
 boolean JxtaBiDiPipe.sendMessage(Message msg)
          Send a message

Messenger

 


JXSE