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.BackOffStrategy, 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

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

org.eclipse.jetty.util.component.Dumpable.DumpableContainer

Field Summary

Fields inherited from class org.cometd.client.BayeuxClient

BACKOFF_INCREMENT_OPTION, BAYEUX_VERSION, logger, MAX_BACKOFF_OPTION

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

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, enqueueSend, getAllowedTransports, getBackoff, getBackoffIncrement, getBackOffStrategy, getCookie, getCookieStore, getId, getKnownTransportNames, getMaxBackoff, getOption, getOptionNames, getOptions, getState, getTransport, getTransport, getURL, 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, setBackOffStrategy, setOption, terminate, waitFor

Methods inherited from class org.cometd.common.AbstractClientSession

addExtension, batch, dump, endBatch, extendIncoming, extendOutgoing, getAttribute, getAttributeNames, getChannel, getChannel, getChannels, getExtensions, isBatching, newMessage, newMessageId, notifyCallback, 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

Methods inherited from interface org.cometd.bayeux.client.ClientSession

disconnect, disconnect, handshake, handshake, handshake

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpSelf

Constructor Detail

OortComet

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

Method Detail

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