org.hornetq.core.remoting.impl.invm

Class InVMConnection

java.lang.Object

org.hornetq.core.remoting.impl.invm.InVMConnection

All Implemented Interfaces:

Connection

public class InVMConnection
extends Object
implements Connection

A InVMConnection

Author:

Tim Fox

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	flushEnabled

Constructor Summary

Constructors

Constructor and Description
InVMConnection(Acceptor acceptor, int serverID, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor)
InVMConnection(Acceptor acceptor, int serverID, String id, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor)
InVMConnection(Acceptor acceptor, int serverID, String id, BufferHandler handler, ConnectionLifeCycleListener listener, Executor executor, HornetQPrincipal defaultHornetQPrincipal)

Method Summary

Methods

Modifier and Type	Method and Description
void	addReadyListener(ReadyListener listener)
void	checkFlushBatchBuffer() Called periodically to flush any data in the batch buffer
void	close() closes this connection.
HornetQBuffer	createBuffer(int size) Create a new HornetQBuffer of the given size.
void	disableFlush()
int	getBatchingBufferSize()
TransportConfiguration	getConnectorConfig() Generates a TransportConfiguration to be use to connect to the same target this is connect to
HornetQPrincipal	getDefaultHornetQPrincipal()
Executor	getExecutor()
Object	getID() returns the unique id of this wire.
String	getRemoteAddress() returns a string representation of the remote address this connection is connected to.
void	removeReadyListener(ReadyListener listener)
String	toString()
void	write(HornetQBuffer buffer) writes the buffer to the connection with no flushing or batching
void	write(HornetQBuffer buffer, boolean flush, boolean batch) writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Methods inherited from class java.lang.Object

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

Field Detail

flushEnabled

public static boolean flushEnabled

Constructor Detail

InVMConnection

public InVMConnection(Acceptor acceptor,
              int serverID,
              BufferHandler handler,
              ConnectionLifeCycleListener listener,
              Executor executor)

InVMConnection

public InVMConnection(Acceptor acceptor,
              int serverID,
              String id,
              BufferHandler handler,
              ConnectionLifeCycleListener listener,
              Executor executor)

InVMConnection

public InVMConnection(Acceptor acceptor,
              int serverID,
              String id,
              BufferHandler handler,
              ConnectionLifeCycleListener listener,
              Executor executor,
              HornetQPrincipal defaultHornetQPrincipal)

Method Detail

close

public void close()

Description copied from interface: Connection

closes this connection.

Specified by:

close in interface Connection

createBuffer

public HornetQBuffer createBuffer(int size)

Description copied from interface: Connection

Create a new HornetQBuffer of the given size.

Specified by:

createBuffer in interface Connection

Parameters:

size - the size of buffer to create

Returns:

the new buffer.

getID

public Object getID()

Description copied from interface: Connection

returns the unique id of this wire.

Specified by:

getID in interface Connection

Returns:

the id

checkFlushBatchBuffer

public void checkFlushBatchBuffer()

Description copied from interface: Connection

Called periodically to flush any data in the batch buffer

Specified by:

checkFlushBatchBuffer in interface Connection

write

public void write(HornetQBuffer buffer)

Description copied from interface: Connection

writes the buffer to the connection with no flushing or batching

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

write

public void write(HornetQBuffer buffer,
         boolean flush,
         boolean batch)

Description copied from interface: Connection

writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Specified by:

write in interface Connection

Parameters:

buffer - the buffer to write

flush - whether to flush the buffers onto the wire

batch - whether the packet is allowed to batched for better performance

getRemoteAddress

public String getRemoteAddress()

Description copied from interface: Connection

returns a string representation of the remote address this connection is connected to.

Specified by:

getRemoteAddress in interface Connection

Returns:

the remote address

getBatchingBufferSize

public int getBatchingBufferSize()

addReadyListener

public void addReadyListener(ReadyListener listener)

Specified by:

addReadyListener in interface Connection

removeReadyListener

public void removeReadyListener(ReadyListener listener)

Specified by:

removeReadyListener in interface Connection

getDefaultHornetQPrincipal

public HornetQPrincipal getDefaultHornetQPrincipal()

Specified by:

getDefaultHornetQPrincipal in interface Connection

disableFlush

public void disableFlush()

getExecutor

public Executor getExecutor()

getConnectorConfig

public TransportConfiguration getConnectorConfig()

Generates a TransportConfiguration to be use to connect to the same target this is connect to

Specified by:

getConnectorConfig in interface Connection

Returns:

toString

public String toString()

Overrides:

toString in class Object