org.jboss.messaging.core.remoting
Interface Channel


public interface Channel

A Channel A Channel *does not* support concurrent access by more than one thread!

Author:
Tim Fox

Method Summary
 void close()
           
 void confirm(Packet packet)
           
 void executeOutstandingDelayedResults()
           
 void flushConfirmations()
           
 RemotingConnection getConnection()
           
 ChannelHandler getHandler()
           
 long getID()
           
 int getLastReceivedCommandID()
           
 java.util.concurrent.locks.Lock getLock()
           
 void lock()
           
 void replayCommands(int lastReceivedCommandID, long newID)
           
 void replicatePacket(Packet packet, long replicatedChannelID, java.lang.Runnable action)
           
 void returnBlocking()
           
 void send(Packet packet)
           
 void sendAndFlush(Packet packet)
           
 Packet sendBlocking(Packet packet)
           
 void setCommandConfirmationHandler(CommandConfirmationHandler handler)
           
 void setHandler(ChannelHandler handler)
           
 void transferConnection(RemotingConnection newConnection, long newID, Channel replicatingChannel)
           
 void unlock()
           
 

Method Detail

getID

long getID()

send

void send(Packet packet)

sendAndFlush

void sendAndFlush(Packet packet)

sendBlocking

Packet sendBlocking(Packet packet)
                    throws MessagingException
Throws:
MessagingException

replicatePacket

void replicatePacket(Packet packet,
                     long replicatedChannelID,
                     java.lang.Runnable action)

setHandler

void setHandler(ChannelHandler handler)

getHandler

ChannelHandler getHandler()

close

void close()

transferConnection

void transferConnection(RemotingConnection newConnection,
                        long newID,
                        Channel replicatingChannel)

replayCommands

void replayCommands(int lastReceivedCommandID,
                    long newID)

getLastReceivedCommandID

int getLastReceivedCommandID()

lock

void lock()

unlock

void unlock()

returnBlocking

void returnBlocking()

getLock

java.util.concurrent.locks.Lock getLock()

getConnection

RemotingConnection getConnection()

executeOutstandingDelayedResults

void executeOutstandingDelayedResults()

confirm

void confirm(Packet packet)

setCommandConfirmationHandler

void setCommandConfirmationHandler(CommandConfirmationHandler handler)

flushConfirmations

void flushConfirmations()


Copyright © 2006 JBoss Inc. All Rights Reserved.