org.jboss.messaging.core.client.impl
Class RemotingConnectionImpl

java.lang.Object
  extended by org.jboss.messaging.core.client.impl.RemotingConnectionImpl
All Implemented Interfaces:
RemotingConnection

public class RemotingConnectionImpl
extends java.lang.Object
implements RemotingConnection

Version:
$Revision: 4304 $ $Id: RemotingConnectionImpl.java 4304 2008-05-27 13:08:44Z jmesnil $
Author:
Tim Fox, Ovidiu Feodorov, Jeff Mesnil

Constructor Summary
RemotingConnectionImpl(Location location, ConnectionParams connectionParams)
           
RemotingConnectionImpl(Location location, ConnectionParams connectionParams, NIOConnector nioConnector)
           
 
Method Summary
 Location getLocation()
           
 PacketDispatcher getPacketDispatcher()
           
 long getSessionID()
           
 Packet sendBlocking(long targetID, long executorID, Packet packet)
          send the packet and block until a response is received (oneWay is set to false)
 void sendOneWay(long targetID, long executorID, Packet packet)
           
 void setRemotingSessionListener(RemotingSessionListener newListener)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RemotingConnectionImpl

public RemotingConnectionImpl(Location location,
                              ConnectionParams connectionParams)
                       throws java.lang.Exception
Throws:
java.lang.Exception

RemotingConnectionImpl

public RemotingConnectionImpl(Location location,
                              ConnectionParams connectionParams,
                              NIOConnector nioConnector)
                       throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

start

public void start()
           throws java.lang.Throwable
Specified by:
start in interface RemotingConnection
Throws:
java.lang.Throwable

stop

public void stop()
Specified by:
stop in interface RemotingConnection

getSessionID

public long getSessionID()
Specified by:
getSessionID in interface RemotingConnection

sendBlocking

public Packet sendBlocking(long targetID,
                           long executorID,
                           Packet packet)
                    throws MessagingException
send the packet and block until a response is received (oneWay is set to false)

Specified by:
sendBlocking in interface RemotingConnection
Throws:
MessagingException

sendOneWay

public void sendOneWay(long targetID,
                       long executorID,
                       Packet packet)
                throws MessagingException
Specified by:
sendOneWay in interface RemotingConnection
Throws:
MessagingException

setRemotingSessionListener

public void setRemotingSessionListener(RemotingSessionListener newListener)
Specified by:
setRemotingSessionListener in interface RemotingConnection

getPacketDispatcher

public PacketDispatcher getPacketDispatcher()
Specified by:
getPacketDispatcher in interface RemotingConnection

getLocation

public Location getLocation()
Specified by:
getLocation in interface RemotingConnection


Copyright © 2006 JBoss Inc. All Rights Reserved.