|
JXTA | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | |||||||||
PREV NEXT | FRAMES NO FRAMES |