Package org.jgroups.protocols

Class STOMP.Connection

java.lang.Object

org.jgroups.protocols.STOMP.Connection

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

STOMP

public class STOMP.Connection
extends java.lang.Object
implements java.lang.Runnable

Class which handles a connection to a client

Field Summary

Fields

Modifier and Type	Field	Description
protected java.io.DataInputStream	in
protected java.io.DataOutputStream	out
protected UUID	session_id
protected java.net.Socket	sock

Constructor Summary

Constructors

Constructor	Description
Connection(java.net.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, java.lang.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 Detail

sock

protected final java.net.Socket sock

in

protected final java.io.DataInputStream in

out

protected final java.io.DataOutputStream out

session_id

protected final UUID session_id

Constructor Detail

Connection

public Connection(java.net.Socket sock)
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

stop

public void stop()

remove

protected void remove()

run

public void run()

Specified by:

run in interface java.lang.Runnable

handleFrame

protected void handleFrame(STOMP.Frame frame)

sendInfo

public void sendInfo()

writeResponse

private void writeResponse(STOMP.ServerVerb response,
                           java.lang.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)