adaptorblockingmessenger.html

jxta的api库

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Returns <code>true</code> if this messenger is not currently sending
 any messages and  the messenger has not been used for "a long time". Thus
 suggesting that closing it would be good.

 <p/>The definition of idleness is up to the implementing message
 transport, but is usually based upon the cost of re-opening a closed
 connection versus continued idleness.

 <p/>This is default implementation.

 <p/>Forwarded to the wrapped messenger.</TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
<CODE>static&nbsp;<A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A></CODE></FONT></TD>
<TD><CODE><B><A HREF="../../../../net/jxta/impl/endpoint/AdaptorBlockingMessenger.html#newBlockingMessenger(net.jxta.endpoint.Messenger)">newBlockingMessenger</A></B>(<A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A>&nbsp;wrapped)</CODE>

<BR>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Returns a non-blocking messenger otherwise equivalent to the provided one.
 </TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD ALIGN="right" VALIGN="top" WIDTH="1%"><FONT SIZE="-1">
<CODE>&nbsp;boolean</CODE></FONT></TD>
<TD><CODE><B><A HREF="../../../../net/jxta/impl/endpoint/AdaptorBlockingMessenger.html#sendMessage(net.jxta.endpoint.Message, java.lang.String, java.lang.String)">sendMessage</A></B>(<A HREF="../../../../net/jxta/endpoint/Message.html" title="class in net.jxta.endpoint">Message</A>&nbsp;msg,
            java.lang.String&nbsp;destService,
            java.lang.String&nbsp;destServiceParam)</CODE>

<BR>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Sends a message to the destination. The message will be sent to the
  location specified by the destination endpoint address. The destination
  address will be modified to include the provided optional service name
  and service parameter.

  <p/><b>WARNING:</b> The Message object should not be reused or modified
  until <code>sendMessage</code> has completed. Concurrent modification of
  a message while a messenger is sending the message will produce
  incorrect and unpredictable results. For asynchronous messengers this 
  method provides no notification of message send completion thus the
  message should <b>never</b> be reused. It is reccommended that a clone
  of the message be provided to send message:

  <p/><code><pre>
      messenger.sendMessage( (Message) myMessage.clone() );
  </pre></code>

  <p/>Error Handling:

  <ul>
  <li>Common Aspects:
      <ul>
          <li>An <CODE>IOException</CODE> means that the message
          was not sent and this messanger cannot be used to send
          subsequent messages. Instances of
          <CODE>RuntimeException</CODE> mean that the message was not
          sent, but retries may or may not be possible based upon the
          status returned by <A HREF="../../../../net/jxta/endpoint/Messenger.html#isClosed()"><CODE>Messenger.isClosed()</CODE></A>.</li>

          <li>A return result of <code>false</code> indicates that the
          message was not accepted to be sent. Usually this is due to
          local resource limits being reached. Attempts may be made to
          later resend the message, usually after waiting for congestion
          to clear.</li>
      </ul>
  </li>

  <li>Synchronous Messengers:
      <ul>
          <li>A return result of <code>true</code> indicates that the
          message was successfully sent. <b>It does not generally imply
          that the destination will successfully receive the message.</b></li>
      </ul>
  </li>

  <li>Asynchronous Messengers:
      <ul>
          <li>A return result of <code>true</code> indicates that the message
          was accepted to be sent. <b>It does not imply that the message
          will be sent or that the destination will receive the message.</b>
          There will be no notification of any errors in sending the
          message.</li>
      </ul></li>
  </ul>

 <p/>Implement a blocking sendMessage on top of the wrapped messenger's
 listener-style call, which may or may not be synchronous; we do not care.
 </TD>
</TR>
</TABLE>
&nbsp;<A NAME="methods_inherited_from_class_net.jxta.impl.endpoint.BlockingMessenger"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#EEEEFF" CLASS="TableSubHeadingColor">
<TD><B>Methods inherited from class net.jxta.impl.endpoint.<A HREF="../../../../net/jxta/impl/endpoint/BlockingMessenger.html" title="class in net.jxta.impl.endpoint">BlockingMessenger</A></B></TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD><CODE><A HREF="../../../../net/jxta/impl/endpoint/BlockingMessenger.html#isSynchronous()">isSynchronous</A>, <A HREF="../../../../net/jxta/impl/endpoint/BlockingMessenger.html#sendMessage(net.jxta.endpoint.Message, java.lang.String, java.lang.String, net.jxta.endpoint.OutgoingMessageEventListener)">sendMessage</A></CODE></TD>
</TR>
</TABLE>
&nbsp;<A NAME="methods_inherited_from_class_net.jxta.impl.endpoint.BasicMessenger"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#EEEEFF" CLASS="TableSubHeadingColor">
<TD><B>Methods inherited from class net.jxta.impl.endpoint.<A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html" title="class in net.jxta.impl.endpoint">BasicMessenger</A></B></TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD><CODE><A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#addPropertyChangeListener(java.beans.PropertyChangeListener)">addPropertyChangeListener</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#equals(java.lang.Object)">equals</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#getDestAddressToUse(java.lang.String, java.lang.String)">getDestAddressToUse</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#getDestinationAddress()">getDestinationAddress</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#getDestinationAddressObject()">getDestinationAddressObject</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#removePropertyChangeListener(java.beans.PropertyChangeListener)">removePropertyChangeListener</A>, <A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#sendMessage(net.jxta.endpoint.Message)">sendMessage</A></CODE></TD>
</TR>
</TABLE>
&nbsp;<A NAME="methods_inherited_from_class_java.lang.Object"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#EEEEFF" CLASS="TableSubHeadingColor">
<TD><B>Methods inherited from class java.lang.Object</B></TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD><CODE>clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</CODE></TD>
</TR>
</TABLE>
&nbsp;<A NAME="methods_inherited_from_class_net.jxta.endpoint.Messenger"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#EEEEFF" CLASS="TableSubHeadingColor">
<TD><B>Methods inherited from interface net.jxta.endpoint.<A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A></B></TD>
</TR>
<TR BGCOLOR="white" CLASS="TableRowColor">
<TD><CODE><A HREF="../../../../net/jxta/endpoint/Messenger.html#hashCode()">hashCode</A></CODE></TD>
</TR>
</TABLE>
&nbsp;
<P>

<!-- ============ FIELD DETAIL =========== -->


<!-- ========= CONSTRUCTOR DETAIL ======== -->

<A NAME="constructor_detail"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#CCCCFF" CLASS="TableHeadingColor">
<TD COLSPAN=1><FONT SIZE="+2">
<B>Constructor Detail</B></FONT></TD>
</TR>
</TABLE>

<A NAME="AdaptorBlockingMessenger(net.jxta.endpoint.Messenger)"><!-- --></A><H3>
AdaptorBlockingMessenger</H3>
<PRE>
public <B>AdaptorBlockingMessenger</B>(<A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A>&nbsp;wrapped)</PRE>
<DL>
<DD>Create a new basic messenger.
<P>
</DL>

<!-- ============ METHOD DETAIL ========== -->

<A NAME="method_detail"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#CCCCFF" CLASS="TableHeadingColor">
<TD COLSPAN=1><FONT SIZE="+2">
<B>Method Detail</B></FONT></TD>
</TR>
</TABLE>

<A NAME="newBlockingMessenger(net.jxta.endpoint.Messenger)"><!-- --></A><H3>
newBlockingMessenger</H3>
<PRE>
public static <A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A> <B>newBlockingMessenger</B>(<A HREF="../../../../net/jxta/endpoint/Messenger.html" title="interface in net.jxta.endpoint">Messenger</A>&nbsp;wrapped)</PRE>
<DL>
<DD>Returns a non-blocking messenger otherwise equivalent to the provided one.
 The messenger returned may be the provided one or a Adaptor one depending
 upon on the synchronicity requirements.
<P>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="close()"><!-- --></A><H3>
close</H3>
<PRE>
public void <B>close</B>()</PRE>
<DL>
<DD>Close this messenger after processing any pending messages. Messengers
  which manage shared resources internally may ignore this operation.
  Specifically:

  <p/><code><pre>
      messenger.close();
      closed = messenger.isClosed();
  </pre></code>

  <p/><code>closed</code> may be <code>false</code>.

 close is forwarded to the wrapped messenger. The closed member inherited
 from BasicMessenger is irrelevant. We map the wrapped messenger
 one-to-one in all cases.
<P>
<DD><DL>
<DT><B>Specified by:</B><DD><CODE><A HREF="../../../../net/jxta/endpoint/EndpointMessenger.html#close()">close</A></CODE> in interface <CODE><A HREF="../../../../net/jxta/endpoint/EndpointMessenger.html" title="interface in net.jxta.endpoint">EndpointMessenger</A></CODE><DT><B>Overrides:</B><DD><CODE><A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html#close()">close</A></CODE> in class <CODE><A HREF="../../../../net/jxta/impl/endpoint/BasicMessenger.html" title="class in net.jxta.impl.endpoint">BasicMessenger</A></CODE></DL>
</DD>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="getLogicalDestinationAddress()"><!-- --></A><H3>
getLogicalDestinationAddress</H3>
<PRE>
public <A HREF="../../../../net/jxta/endpoint/EndpointAddress.html" title="class in net.jxta.endpoint">EndpointAddress</A> <B>getLogicalDestinationAddress</B>()</PRE>
<DL>
<DD>Returns the logical destination of this messenger. This may be a
  different address than is returned by
  <A HREF="../../../../net/jxta/endpoint/EndpointMessenger.html#getDestinationAddress()"><CODE>getDestinationAddress</CODE></A> and refers to
  the entity which is located at the destination address.