Package org.jgroups.protocols

Class STOMP.Connection

java.lang.Object

org.jgroups.protocols.STOMP.Connection

All Implemented Interfaces:

Runnable

Enclosing class:

STOMP

public class STOMP.Connection
extends Object
implements Runnable

Class which handles a connection to a client

Field Summary

Fields

Modifier and Type	Field	Description
protected final DataInputStream	in
protected final DataOutputStream	out
protected final UUID	session_id
protected final Socket	sock

Constructor Summary

Constructors

Constructor	Description
Connection(Socket sock)

Method Summary

Modifier and Type	Method	Description
protected void	handleFrame(STOMP.Frame frame)
protected void	remove()
void	run()
void	sendInfo()
void	stop()
private void	writeResponse(byte[] response, int offset, int length)
private void	writeResponse(STOMP.ServerVerb response, String... keys_and_values)	Sends back a response.

Methods inherited from class java.lang.Object

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

Field Details

sock

protected final Socket sock

in

protected final DataInputStream in

out

protected final DataOutputStream out

session_id

protected final UUID session_id

Constructor Details

Connection

public Connection(Socket sock)
           throws IOException

Throws:

IOException

Method Details

stop

public void stop()

remove

protected void remove()

run

public void run()

Specified by:

run in interface Runnable

handleFrame

protected void handleFrame(STOMP.Frame frame)

sendInfo

public void sendInfo()

writeResponse

private void writeResponse(STOMP.ServerVerb response,
 String... keys_and_values)

Sends back a response. The keys_and_values vararg array needs to have an even number of elements

Parameters:

response -

keys_and_values -

writeResponse

private void writeResponse(byte[] response,
 int offset,
 int length)