org.hornetq.core.remoting.server.impl

Class RemotingServiceImpl

java.lang.Object

org.hornetq.core.remoting.server.impl.RemotingServiceImpl

All Implemented Interfaces:

RemotingService, ConnectionLifeCycleListener

public class RemotingServiceImpl
extends Object
implements RemotingService, ConnectionLifeCycleListener

Version:

$Revision$

Author:

Jeff Mesnil, Andy Taylor, Tim Fox

Field Summary

Fields

Modifier and Type	Field and Description
static long	CONNECTION_TTL_CHECK_INTERVAL

Constructor Summary

Constructors

Constructor and Description
RemotingServiceImpl(ClusterManager clusterManager, Configuration config, HornetQServer server, ManagementService managementService, ScheduledExecutorService scheduledThreadPool)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInterceptor(Interceptor interceptor)
void	allowInvmSecurityOverride(HornetQPrincipal principal)
void	connectionCreated(Acceptor acceptor, Connection connection, ProtocolType protocol) This method is used both by client connector creation and server connection creation through acceptors.
void	connectionDestroyed(Object connectionID) called when a connection is destroyed.
void	connectionException(Object connectionID, HornetQException me) called when an error occurs on the connection.
void	connectionReadyForWrites(Object connectionID, boolean ready)
void	freeze()
Set<RemotingConnection>	getConnections()
RemotingConnection	getServerSideReplicatingConnection()
boolean	isStarted()
RemotingConnection	removeConnection(Object remotingConnectionID) Remove a connection from the connections held by the remoting service.
boolean	removeInterceptor(Interceptor interceptor)
void	start()
void	stop(boolean criticalError)

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTION_TTL_CHECK_INTERVAL

public static final long CONNECTION_TTL_CHECK_INTERVAL

See Also:

Constant Field Values

Constructor Detail

RemotingServiceImpl

public RemotingServiceImpl(ClusterManager clusterManager,
                   Configuration config,
                   HornetQServer server,
                   ManagementService managementService,
                   ScheduledExecutorService scheduledThreadPool)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface RemotingService

Throws:

Exception

allowInvmSecurityOverride

public void allowInvmSecurityOverride(HornetQPrincipal principal)

Specified by:

allowInvmSecurityOverride in interface RemotingService

freeze

public void freeze()

Specified by:

freeze in interface RemotingService

stop

public void stop(boolean criticalError)
          throws Exception

Specified by:

stop in interface RemotingService

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface RemotingService

removeConnection

public RemotingConnection removeConnection(Object remotingConnectionID)

Description copied from interface: RemotingService

Remove a connection from the connections held by the remoting service. This method must be used only from the management API. RemotingConnections are removed from the remoting service when their connectionTTL is hit.

Specified by:

removeConnection in interface RemotingService

Parameters:

remotingConnectionID - the ID of the RemotingConnection to removed

Returns:

the removed RemotingConnection

getConnections

public Set<RemotingConnection> getConnections()

Specified by:

getConnections in interface RemotingService

getServerSideReplicatingConnection

public RemotingConnection getServerSideReplicatingConnection()

Specified by:

getServerSideReplicatingConnection in interface RemotingService

connectionCreated

public void connectionCreated(Acceptor acceptor,
                     Connection connection,
                     ProtocolType protocol)

Description copied from interface: ConnectionLifeCycleListener

This method is used both by client connector creation and server connection creation through acceptors. the acceptor will be set to null on client operations

Specified by:

connectionCreated in interface ConnectionLifeCycleListener

connection - the connection that has been created

connectionDestroyed

public void connectionDestroyed(Object connectionID)

Description copied from interface: ConnectionLifeCycleListener

called when a connection is destroyed.

Specified by:

connectionDestroyed in interface ConnectionLifeCycleListener

Parameters:

connectionID - the connection being destroyed.

connectionException

public void connectionException(Object connectionID,
                       HornetQException me)

Description copied from interface: ConnectionLifeCycleListener

called when an error occurs on the connection.

Specified by:

connectionException in interface ConnectionLifeCycleListener

Parameters:

connectionID - the id of the connection.

me - the exception.

connectionReadyForWrites

public void connectionReadyForWrites(Object connectionID,
                            boolean ready)

Specified by:

connectionReadyForWrites in interface ConnectionLifeCycleListener

addInterceptor

public void addInterceptor(Interceptor interceptor)

Specified by:

addInterceptor in interface RemotingService

removeInterceptor

public boolean removeInterceptor(Interceptor interceptor)

Specified by:

removeInterceptor in interface RemotingService