org.jboss.messaging.core.remoting
Interface RemotingConnection

All Superinterfaces:
BufferHandler
All Known Implementing Classes:
RemotingConnectionImpl

public interface RemotingConnection
extends BufferHandler

A RemotingConnection

Author:
Tim Fox, Jeff Mesnil

Method Summary
 void activate()
           
 void addCloseListener(CloseListener listener)
           
 void addFailureListener(FailureListener listener)
           
 MessagingBuffer createBuffer(int size)
           
 void destroy()
           
 void fail(MessagingException me)
           
 void freeze()
           
 long generateChannelID()
           
 long getBlockingCallTimeout()
           
 Channel getChannel(long channelID, int windowSize, boolean block)
           
 java.util.List<FailureListener> getFailureListeners()
           
 java.lang.Object getID()
           
 long getIDGeneratorSequence()
           
 java.lang.String getRemoteAddress()
           
 java.lang.Object getTransferLock()
           
 Connection getTransportConnection()
           
 boolean isActive()
           
 boolean isClient()
           
 boolean isDestroyed()
           
 void putChannel(long channelID, Channel channel)
           
 boolean removeChannel(long channelID)
           
 boolean removeCloseListener(CloseListener listener)
           
 boolean removeFailureListener(FailureListener listener)
           
 void setFailureListeners(java.util.List<FailureListener> listeners)
           
 void syncIDGeneratorSequence(long id)
           
 
Methods inherited from interface org.jboss.messaging.core.remoting.spi.BufferHandler
bufferReceived, isReadyToHandle
 

Method Detail

getID

java.lang.Object getID()

getRemoteAddress

java.lang.String getRemoteAddress()

getChannel

Channel getChannel(long channelID,
                   int windowSize,
                   boolean block)

putChannel

void putChannel(long channelID,
                Channel channel)

removeChannel

boolean removeChannel(long channelID)

generateChannelID

long generateChannelID()

addFailureListener

void addFailureListener(FailureListener listener)

removeFailureListener

boolean removeFailureListener(FailureListener listener)

addCloseListener

void addCloseListener(CloseListener listener)

removeCloseListener

boolean removeCloseListener(CloseListener listener)

getFailureListeners

java.util.List<FailureListener> getFailureListeners()

setFailureListeners

void setFailureListeners(java.util.List<FailureListener> listeners)

createBuffer

MessagingBuffer createBuffer(int size)

fail

void fail(MessagingException me)

destroy

void destroy()

syncIDGeneratorSequence

void syncIDGeneratorSequence(long id)

getIDGeneratorSequence

long getIDGeneratorSequence()

activate

void activate()

freeze

void freeze()

getTransportConnection

Connection getTransportConnection()

isActive

boolean isActive()

isClient

boolean isClient()

isDestroyed

boolean isDestroyed()

getBlockingCallTimeout

long getBlockingCallTimeout()

getTransferLock

java.lang.Object getTransferLock()


Copyright © 2006 JBoss Inc. All Rights Reserved.