Package org.cometd.oort

Class OortComet

java.lang.Object

org.cometd.common.AbstractClientSession

org.cometd.client.BayeuxClient

org.cometd.oort.OortComet

All Implemented Interfaces:

Bayeux, ClientSession, Session, org.eclipse.jetty.util.component.Dumpable

public class OortComet
extends BayeuxClient

The Oort comet client connects a local Oort comet server to a remote Oort comet server.

Nested Class Summary

Nested classes/interfaces inherited from class org.cometd.client.BayeuxClient

BayeuxClient.BayeuxClientChannel, BayeuxClient.State

Nested classes/interfaces inherited from class org.cometd.common.AbstractClientSession

AbstractClientSession.AbstractSessionChannel

Nested classes/interfaces inherited from interface org.cometd.bayeux.Bayeux

Bayeux.BayeuxListener

Nested classes/interfaces inherited from interface org.cometd.bayeux.client.ClientSession

ClientSession.Extension, ClientSession.MessageListener

Field Summary

Fields inherited from class org.cometd.client.BayeuxClient

BACKOFF_INCREMENT_OPTION, BAYEUX_VERSION, logger, MAX_BACKOFF_OPTION

Constructor Summary

Constructors

Constructor	Description
OortComet(Oort oort, String cometURL, ScheduledExecutorService scheduler, ClientTransport transport, ClientTransport... transports)

Method Summary

Modifier and Type	Method	Description
protected void	clearSubscriptions()
protected void	subscribe(Set<String> observedChannels)
String	toString()
protected void	unsubscribe(String channel)

Methods inherited from class org.cometd.client.BayeuxClient

abort, disconnect, disconnect, disconnect, enqueueSend, getAllowedTransports, getBackoff, getBackoffIncrement, getCookie, getCookieStore, getId, getKnownTransportNames, getMaxBackoff, getOption, getOptionNames, getOptions, getState, getTransport, getTransport, getURL, handshake, handshake, handshake, handshake, handshake, handshake, initialize, isConnected, isDisconnected, isHandshook, messagesFailure, newChannel, newChannelId, onFailure, onMessages, onSending, onTransportFailure, onTransportFailure, processConnect, processDisconnect, processHandshake, processMessage, putCookie, scheduleConnect, scheduleHandshake, send, sendBatch, sendConnect, sendHandshake, sendMessages, setOption, terminate, waitFor

Methods inherited from class org.cometd.common.AbstractClientSession

addExtension, batch, dump, dump, endBatch, extendRcv, extendSend, getAttribute, getAttributeNames, getChannel, getChannel, getChannels, getExtensions, isBatching, newMessage, newMessageId, notifyListener, notifyListeners, receive, registerCallback, registerSubscriber, remoteCall, removeAttribute, removeExtension, resetSubscriptions, setAttribute, startBatch, unregisterCallback, unregisterSubscriber

Methods inherited from class java.lang.Object

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

Constructor Details

OortComet

public OortComet(Oort oort, String cometURL, ScheduledExecutorService scheduler, ClientTransport transport, ClientTransport... transports)

Method Details

subscribe

protected void subscribe(Set<String> observedChannels)

unsubscribe

protected void unsubscribe(String channel)

clearSubscriptions

protected void clearSubscriptions()

toString

public String toString()

Overrides:

toString in class BayeuxClient