|
Project JXTA | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.jxta.util.AbstractSimpleSelectable
net.jxta.endpoint.AbstractMessenger
net.jxta.impl.endpoint.BlockingMessenger
net.jxta.impl.endpoint.cbjx.CbJxMessenger
This class is the Messenger used to send CbJx Messages
Nested Class Summary |
Nested classes inherited from class net.jxta.util.SimpleSelectable |
SimpleSelectable.IdentityReference |
Field Summary |
Fields inherited from class net.jxta.endpoint.AbstractMessenger |
DEFAULT_MTU, dstAddress |
Fields inherited from class net.jxta.util.AbstractSimpleSelectable |
identityReference |
Fields inherited from interface net.jxta.endpoint.Messenger |
ANYSTATE, BREAKING, BROKEN, CLOSED, CLOSING, CONNECTED, DISCONNECTED, DISCONNECTING, IDLE, RECONCLOSING, RECONNECTING, RECONSATURATED, RESOLCLOSING, RESOLPENDING, RESOLSATURATED, RESOLVED, RESOLVING, SATURATED, SENDING, SENDINGSATURATED, TERMINAL, UNRESOLVABLE, UNRESOLVED, UNRESOLVING, USABLE |
Constructor Summary | |
CbJxMessenger(CbJxTransport transport,
EndpointAddress dest)
constructor |
|
CbJxMessenger(CbJxTransport transport,
EndpointAddress dest,
Object hintIgnored)
constructor |
Method Summary | |
void |
closeImpl()
Close connection. May fail current send. |
EndpointAddress |
getLogicalDestinationImpl()
Obtain the logical destination address from the implementer (a transport for example). |
boolean |
isClosed()
We overload isClosed because many messengers still invoke super.isClosed() for their own implementation and they expect it to be true only when all is shutdown; not while we're closing gently. FIXME - jice@jxta.org 20040413: transports should get a deeper retrofit eventually. |
boolean |
isIdleImpl()
return true if this messenger has not been used for a long time. The definition of long time is: "so long that closing it is worth the risk of having to re-open". A messenger should self close if it thinks it meets the definition of idle. BlockingMessenger leaves the evaluation to the transport but does the work automatically. Important: if self destruction is used, this method must work; not just return false. See the constructor. In general, if closeImpl does not need to do anyhing, then self destruction is not needed. |
boolean |
sendMessageBImpl(Message msg,
String service,
String serviceParam)
send message. block as needed. throw IOException or runtime exception as needed. The boolean return value is for historical reasons: so that transports just need to rename their sendMessage() methods. No need to change a bit of the code. |
(package private) boolean |
sendTo(Message msg)
sendTo is used in order to send a message via the underlying messenger |
Methods inherited from class net.jxta.impl.endpoint.BlockingMessenger |
close, getChannelMessenger, getDestAddressToUse, getLogicalDestinationAddress, getState, resolve, sendMessageB, sendMessageN, setOwner, shutdown |
Methods inherited from class net.jxta.endpoint.AbstractMessenger |
flush, getDestinationAddress, getDestinationAddressObject, getMTU, isIdle, isSynchronous, itemChanged, sendMessage, sendMessage, sendMessage, setStateLock, waitState |
Methods inherited from class net.jxta.util.AbstractSimpleSelectable |
getIdentityReference, haveListeners, notifyChange, register, registerListener, unregister, unregisterListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface net.jxta.util.SimpleSelectable |
getIdentityReference, register, unregister |
Constructor Detail |
public CbJxMessenger(CbJxTransport transport, EndpointAddress dest, Object hintIgnored) throws IOException
dest
- the destination addresspublic CbJxMessenger(CbJxTransport transport, EndpointAddress dest) throws IOException
dest
- the destination addressMethod Detail |
public void closeImpl()
closeImpl
in class BlockingMessenger
public EndpointAddress getLogicalDestinationImpl()
getLogicalDestinationImpl
in class BlockingMessenger
public boolean isClosed()
isClosed
in interface Messenger
isClosed
in class BlockingMessenger
public boolean isIdleImpl()
isIdleImpl
in class BlockingMessenger
public boolean sendMessageBImpl(Message msg, String service, String serviceParam) throws IOException
sendMessageBImpl
in class BlockingMessenger
IOException
boolean sendTo(Message msg) throws IOException
IOException
- if there was a problem sending the message.
|
JXTA J2SE | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |