[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport ...

[Ovidiu Feodorov]

  User: ovidiu  
  Date: 07/01/21 03:38:33

  Modified:    src/main/org/jboss/remoting/transport  Tag: remoting_2_x
                        ClientInvoker.java
  Log:
  http://jira.jboss.org/jira/browse/JBREM-681
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.7.2.5   +43 -40    JBossRemoting/src/main/org/jboss/remoting/transport/ClientInvoker.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ClientInvoker.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/ClientInvoker.java,v
  retrieving revision 1.7.2.4
  retrieving revision 1.7.2.5
  diff -u -b -r1.7.2.4 -r1.7.2.5
  --- ClientInvoker.java	21 Jan 2007 01:16:42 -0000	1.7.2.4
  +++ ClientInvoker.java	21 Jan 2007 08:38:33 -0000	1.7.2.5
  @@ -39,86 +39,89 @@
    * and RemoteClientInvoker).
    *
    * @author <a href="mailto:telrod at e2technologies.net">Tom Elrod</a>
  + * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
    */
   public interface ClientInvoker extends Invoker
   {
      /**
  -    * This should be set when want to override the default behavior of automatically
  -    * getting s suitable locator.  This should be used want want to control what type
  -    * of callbacks to receive (pull or push).  Set to null to poll for callback messages.
  -    * This can also be used to receive callbacks using another transport and subsystem,
  -    * if desired.
  -    * @param sessionId
  -    * @param locator
  -    *
  -    * @return id for callback handler and locator combination
  -    */
  -   public String addClientLocator(String sessionId, InvokerCallbackHandler callbackhandler, InvokerLocator locator);
  +    * This should be set when want to override the default behavior of automatically getting a
  +    * suitable locator. This should be used want want to control what type of callbacks to receive
  +    * (pull or push).  Set to null to poll for callback messages. This can also be used to receive
  +    * callbacks using another transport and subsystem, if desired.
  +    *
  +    * @return id for callback handler and locator combination.
  +    */
  +   String addClientLocator(String sessionId,
  +                           InvokerCallbackHandler callbackhandler,
  +                           InvokerLocator locator);
   
      /**
       * Gets the client locator.  This locator will be used by the server side
       * to make callbacks to the handler for this locator.
       */
  -   public InvokerLocator getClientLocator(String listenerId);
  +   InvokerLocator getClientLocator(String listenerId);
   
      /**
       * Gets list of AbstractInvoker.CallbackLocatorHolder containing listener id and locator
       */
  -   public List getClientLocators(String sessionId, InvokerCallbackHandler handler);
  +   List getClientLocators(String sessionId, InvokerCallbackHandler handler);
   
      /**
       * Gets SocketFactory used to connect to ServerInvoker.
       */
  -   public SocketFactory getSocketFactory();
  +   SocketFactory getSocketFactory();
   
      /**
       * Sets the SocketFactory that will be used to connect to ServerInvoker.
       *
       * @param socketFactory
       */
  -   public void setSocketFactory(SocketFactory socketFactory);
  +   void setSocketFactory(SocketFactory socketFactory);
   
      /**
  -    * transport a request against a remote ServerInvoker
  -    *
  -    * @param in
  -    * @return
  -    * @throws Throwable
  +    * Transport a request against a remote ServerInvoker.
       */
  -   public Object invoke(InvocationRequest in) throws Throwable;
  +   Object invoke(InvocationRequest in) throws Throwable;
   
      /**
  -    * subclasses must provide this method to return true if their remote connection is connected and
  -    * false if disconnected.  in some transports, such as SOAP, this method may always return true, since the
  -    * remote connectivity is done on demand and not kept persistent like other transports (such as socket-based
  -    * transport).
  +    * Subclasses must provide this method to return true if their remote connection is connected and
  +    * false if disconnected.  In some transports, such as SOAP, this method may always return true,
  +    * since the remote connectivity is done on demand and not kept persistent like other transports
  +    * (such as socket-based transport).
       *
  -    * @return boolean true if connected, false if not
  +    * @return boolean true if connected, false if not.
       */
  -   public boolean isConnected();
  +   boolean isConnected();
   
      /**
  -    * connect to the remote invoker
  -    *
  -    * @throws org.jboss.remoting.ConnectionFailedException
  -    *
  +    * Connect to the remote invoker.
       */
  -   public void connect() throws ConnectionFailedException;
  +   void connect() throws ConnectionFailedException;
   
      /**
  -    * disconnect from the remote invokere
  +    * Disconnect from the remote invokere.
       */
  -   public void disconnect();
  +   void disconnect();
  +
  +   void setMarshaller(Marshaller marshaller);
   
  -   public void setMarshaller(Marshaller marshaller);
  +   Marshaller getMarshaller();
   
  -   public Marshaller getMarshaller();
  +   void setUnMarshaller(UnMarshaller unmarshaller);
   
  -   public void setUnMarshaller(UnMarshaller unmarshaller);
  +   UnMarshaller getUnMarshaller();
   
  -   public UnMarshaller getUnMarshaller();
  +   void establishLease(String sessionID, Map configuration, long leasePeriod) throws Throwable;
   
  -   public void establishLease(String sessionId, Map configuration, long leasePeriod) throws Throwable;
  +   /**
  +    * Must behave as a noop if there's no active lease.
  +    */
  +   void terminateLease(String sessionID, boolean local);
  +
  +   /**
  +    * @return the lease period (in ms) if the client has an active leasing mechanism with the server
  +    *         or -1 otherwise.
  +    */
  +   long getLeasePeriod(String sessionID);
   
  -   public void terminateLease(String sessionId, boolean local);
   }
  \ No newline at end of file