StompConnection

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jgroups.client
Class StompConnection

java.lang.Object
  org.jgroups.client.StompConnection

All Implemented Interfaces:: java.lang.Runnable

public class StompConnection
extends java.lang.Object
implements java.lang.Runnable
extends java.lang.Object
implements java.lang.Runnable

STOMP client to access the STOMP [1] protocol. Note that the full STOMP protocol is not implemented, e.g. transactions are currently not supported.

The interactive client can be started with -h HOST -p PORT, which are the hostname and port of a JGroups server, running with STOMP in its stack configuration. The interactive client supports automatic failover to a different server if the currently connected-to server crashes, and a simple syntax for sending STOMP messages:

 subscribe DEST // example: subscribe /topics/a
 send DEST message // example: send /topics/a Hello world

[1] http://stomp.codehaus.org/Protocol

Author:: Bela Ban

Nested Class Summary
`static interface`	`StompConnection.Listener`

Field Summary
`protected java.io.DataInputStream`	`in`
`protected java.util.Set<StompConnection.Listener>`	`listeners`
`protected Log`	`log`
`protected java.io.DataOutputStream`	`out`
`protected java.lang.String`	`password`
`protected boolean`	`reconnect`
`protected java.lang.Thread`	`runner`
`protected boolean`	`running`
`protected java.util.Set<java.lang.String>`	`server_destinations`
`protected java.lang.String`	`session_id`
`protected java.net.Socket`	`sock`
`protected javax.net.SocketFactory`	`socket_factory`
`protected java.util.Set<java.lang.String>`	`subscriptions`
`protected java.lang.String`	`userid`

Constructor Summary
`StompConnection(java.lang.String dest)`
`StompConnection(java.lang.String dest, boolean reconnect, boolean ssl)`
`StompConnection(java.lang.String dest, java.lang.String userid, java.lang.String password, boolean reconnect, boolean ssl)`

Method Summary
`void`	`addListener(StompConnection.Listener listener)`
`protected void`	`closeConnections()`
`void`	`connect()`
`protected void`	`connectToDestination(java.lang.String dest)`
`void`	`disconnect()`
`java.lang.String`	`getSessionId()`
`boolean`	`isConnected()`
`static void`	`main(java.lang.String[] args)`
`protected void`	`notifyListeners(java.util.Map<java.lang.String,java.lang.String> info)`
`protected void`	`notifyListeners(java.util.Map<java.lang.String,java.lang.String> headers, byte[] buf, int offset, int length)`
`void`	`removeListener(StompConnection.Listener listener)`
`void`	`run()`
`void`	`send(java.lang.String destination, byte[] buf)`
`void`	`send(java.lang.String destination, byte[] buf, int offset, int length)`
`void`	`send(java.lang.String destination, byte[] buf, int offset, int length, java.lang.String... headers)`
`void`	`send(java.lang.String destination, java.lang.String... headers)` Sends an INFO without body
`protected void`	`sendConnect()`
`protected void`	`sendSubscribe(java.lang.String destination)`
`protected void`	`sendUnsubscribe(java.lang.String destination)`
`void`	`startReconnectingClient()`
`protected void`	`startRunner()`
`void`	`subscribe(java.lang.String destination)`
`void`	`unsubscribe(java.lang.String destination)`

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Field Detail

socket_factory

protected javax.net.SocketFactory socket_factory

sock

protected java.net.Socket sock

in

protected java.io.DataInputStream in

out

protected java.io.DataOutputStream out

server_destinations

protected final java.util.Set<java.lang.String> server_destinations

listeners

protected final java.util.Set<StompConnection.Listener> listeners

subscriptions

protected final java.util.Set<java.lang.String> subscriptions

runner

protected java.lang.Thread runner

running

protected volatile boolean running

session_id

protected java.lang.String session_id

userid

protected java.lang.String userid

password

protected java.lang.String password

reconnect

protected boolean reconnect

log

protected final Log log

Constructor Detail