org.jboss.jms.client.delegate
Class ClientBrowserDelegate

java.lang.Object
  org.jboss.jms.client.delegate.DelegateSupport
      org.jboss.jms.client.delegate.ClientBrowserDelegate

All Implemented Interfaces:

java.io.Serializable, Closeable, BrowserDelegate, BrowserEndpoint, Streamable

public class ClientBrowserDelegate
extends DelegateSupport
implements BrowserDelegate

The client-side Browser delegate class.

Version:

$Revision: 3174 $ $Id: ClientBrowserDelegate.java 3174 2007-10-05 15:14:57Z timfox $

Author:

Tim Fox, Ovidiu Feodorov

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.jms.client.delegate.DelegateSupport

client, id, state, version

Constructor Summary

ClientBrowserDelegate()

ClientBrowserDelegate(java.lang.String objectID)

Method Summary

void	close() Close the instance
long	closing(long sequence) Tell the instance to prepare to close
java.lang.String	getStackName()
boolean	hasNextMessage()
JBossMessage	nextMessage()
JBossMessage[]	nextMessageBlock(int maxMessages)
void	read(java.io.DataInputStream in)
void	reset() Reset the internal state of the browser endpoint so the following nextMessage()/hasNextMessage()/nextMessageBlock() invocations would reflect the state of the queue at the moment of the reset.
void	setState(HierarchicalState state)
void	synchronizeWith(DelegateSupport nd) During HA events, delegates corresponding to new enpoints on the new server are created and the state of those delegates has to be transfered to the "failed" delegates.
java.lang.String	toString()
void	write(java.io.DataOutputStream out)

Methods inherited from class org.jboss.jms.client.delegate.DelegateSupport

doInvoke, doInvokeOneway, getClient, getID, getName, getState, handleThrowable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClientBrowserDelegate

public ClientBrowserDelegate(java.lang.String objectID)

ClientBrowserDelegate

public ClientBrowserDelegate()

Method Detail

synchronizeWith

public void synchronizeWith(DelegateSupport nd)
                     throws java.lang.Exception

Description copied from class: DelegateSupport

During HA events, delegates corresponding to new enpoints on the new server are created and the state of those delegates has to be transfered to the "failed" delegates. For example, a "failed" connection delegate will have to assume the ID of the new connection endpoint, the new RemotingConnection instance, etc.

Overrides:

synchronizeWith in class DelegateSupport

Throws:

java.lang.Exception

setState

public void setState(HierarchicalState state)

Overrides:

setState in class DelegateSupport

close

public void close()
           throws JMSException

Description copied from interface: Closeable

Close the instance

Specified by:

close in interface Closeable

Throws:

JMSException

closing

public long closing(long sequence)
             throws JMSException

Description copied from interface: Closeable

Tell the instance to prepare to close

Specified by:

closing in interface Closeable

Throws:

JMSException

reset

public void reset()
           throws JMSException

Description copied from interface: BrowserEndpoint

Reset the internal state of the browser endpoint so the following nextMessage()/hasNextMessage()/nextMessageBlock() invocations would reflect the state of the queue at the moment of the reset.

Specified by:

reset in interface BrowserEndpoint

Throws:

JMSException

hasNextMessage

public boolean hasNextMessage()
                       throws JMSException

Specified by:

hasNextMessage in interface BrowserEndpoint

Throws:

JMSException

nextMessage

public JBossMessage nextMessage()
                         throws JMSException

Specified by:

nextMessage in interface BrowserEndpoint

Throws:

JMSException

nextMessageBlock

public JBossMessage[] nextMessageBlock(int maxMessages)
                                throws JMSException

Specified by:

nextMessageBlock in interface BrowserEndpoint

Throws:

JMSException

read

public void read(java.io.DataInputStream in)
          throws java.lang.Exception

Specified by:

read in interface Streamable

Overrides:

read in class DelegateSupport

Throws:

java.lang.Exception

write

public void write(java.io.DataOutputStream out)
           throws java.lang.Exception

Specified by:

write in interface Streamable

Overrides:

write in class DelegateSupport

Throws:

java.lang.Exception

getStackName

public java.lang.String getStackName()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object