org.jboss.messaging.core.client.impl
Class RemotingConnectionImpl
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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.