|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
---|---|
org.cometd | |
org.cometd.client | |
org.cometd.client.ext | |
org.cometd.examples | |
org.cometd.oort | |
org.cometd.server | |
org.cometd.server.ext |
Uses of Message in org.cometd |
---|
Methods in org.cometd that return Message | |
---|---|
Message |
Message.getAssociated()
|
Message |
Extension.rcv(Client from,
Message message)
|
Message |
Extension.rcvMeta(Client from,
Message message)
|
Message |
Extension.send(Client from,
Message message)
|
Message |
Extension.sendMeta(Client from,
Message message)
|
Methods in org.cometd that return types with arguments of type Message | |
---|---|
java.util.Queue<Message> |
Client.getQueue()
|
java.util.List<Message> |
Client.takeMessages()
Deprecated. use Client.addListener(ClientListener) to be notified of messages |
Methods in org.cometd with parameters of type Message | |
---|---|
boolean |
SecurityPolicy.canCreate(Client client,
java.lang.String channel,
Message message)
Test if a message should be allowed to create a new Channel |
boolean |
SecurityPolicy.canHandshake(Message message)
Test if a handshake message should be accepted. |
boolean |
SecurityPolicy.canPublish(Client client,
java.lang.String channel,
Message messsage)
Test if a client can publish a message to a channel |
boolean |
SecurityPolicy.canSubscribe(Client client,
java.lang.String channel,
Message messsage)
Test if a client is allowed to subscribe to a channel |
void |
MessageListener.deliver(Client fromClient,
Client toClient,
Message msg)
Called when a message is delivered to the client |
boolean |
QueueListener.queueMaxed(Client from,
Client to,
Message message)
Call back to notify if a message for a client will result in the message queue exceeding Client.getMaxQueue() . |
Message |
Extension.rcv(Client from,
Message message)
|
Message |
Extension.rcvMeta(Client from,
Message message)
|
Message |
Extension.send(Client from,
Message message)
|
Message |
Extension.sendMeta(Client from,
Message message)
|
Method parameters in org.cometd with type arguments of type Message | |
---|---|
void |
DeliverListener.deliver(Client client,
java.util.Queue<Message> queue)
callback to notify that the queue is about to be sent to the client. |
Uses of Message in org.cometd.client |
---|
Methods in org.cometd.client that return Message | |
---|---|
protected Message[] |
BayeuxClient.Publish.getOutboundMessages()
|
Methods in org.cometd.client that return types with arguments of type Message | |
---|---|
java.util.Queue<Message> |
BayeuxClient.getQueue()
|
java.util.List<Message> |
BayeuxClient.takeMessages()
|
Methods in org.cometd.client with parameters of type Message | |
---|---|
void |
BayeuxClient.deliver(Client from,
Message message)
(non-Javadoc) |
protected void |
BayeuxClient.extendIn(Message message)
Called to extend inbound messages |
protected void |
BayeuxClient.extendOut(Message message)
Called to extend outbound messages |
protected void |
BayeuxClient.metaConnect(boolean success,
Message message)
Called with the results of a /meta/connect message |
protected void |
BayeuxClient.metaHandshake(boolean success,
boolean reestablish,
Message message)
Called with the results of a /meta/handshake message |
protected void |
BayeuxClient.metaPublishFail(java.lang.Throwable e,
Message[] messages)
Called with the results of a failed publish |
Uses of Message in org.cometd.client.ext |
---|
Methods in org.cometd.client.ext that return Message | |
---|---|
Message |
TimesyncClientExtension.rcv(Client from,
Message message)
|
Message |
AckExtension.rcv(Client from,
Message message)
|
Message |
TimesyncClientExtension.rcvMeta(Client from,
Message message)
|
Message |
AckExtension.rcvMeta(Client from,
Message message)
|
Message |
TimesyncClientExtension.send(Client from,
Message message)
|
Message |
AckExtension.send(Client from,
Message message)
|
Message |
TimesyncClientExtension.sendMeta(Client from,
Message message)
|
Message |
AckExtension.sendMeta(Client from,
Message message)
|
Methods in org.cometd.client.ext with parameters of type Message | |
---|---|
Message |
TimesyncClientExtension.rcv(Client from,
Message message)
|
Message |
AckExtension.rcv(Client from,
Message message)
|
Message |
TimesyncClientExtension.rcvMeta(Client from,
Message message)
|
Message |
AckExtension.rcvMeta(Client from,
Message message)
|
Message |
TimesyncClientExtension.send(Client from,
Message message)
|
Message |
AckExtension.send(Client from,
Message message)
|
Message |
TimesyncClientExtension.sendMeta(Client from,
Message message)
|
Message |
AckExtension.sendMeta(Client from,
Message message)
|
Uses of Message in org.cometd.examples |
---|
Methods in org.cometd.examples with parameters of type Message | |
---|---|
void |
CometdDemoServlet.Monitor.monitorMeta(Client client,
Message message)
|
void |
CometdDemoServlet.Monitor.monitorSubscribe(Client client,
Message message)
|
void |
CometdDemoServlet.Monitor.monitorUnsubscribe(Client client,
Message message)
|
Uses of Message in org.cometd.oort |
---|
Methods in org.cometd.oort that return Message | |
---|---|
Message |
Oort.OortExtension.rcv(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.rcv(Client from,
Message message)
|
Message |
Oort.OortExtension.rcvMeta(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.rcvMeta(Client from,
Message message)
|
Message |
Oort.OortExtension.send(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.send(Client from,
Message message)
|
Message |
Oort.OortExtension.sendMeta(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.sendMeta(Client from,
Message message)
|
Methods in org.cometd.oort with parameters of type Message | |
---|---|
void |
OortComet.OortCometListener.deliver(Client fromClient,
Client toClient,
Message msg)
|
void |
Oort.RootOortClientListener.deliver(Client fromClient,
Client toClient,
Message msg)
|
protected void |
OortComet.metaConnect(boolean success,
Message message)
|
protected void |
OortComet.metaHandshake(boolean success,
boolean reestablish,
Message message)
|
protected void |
OortComet.metaPublishFail(java.lang.Throwable e,
Message[] messages)
|
boolean |
Oort.RemoteOortClientExtension.queueMaxed(Client from,
Client client,
Message message)
|
Message |
Oort.OortExtension.rcv(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.rcv(Client from,
Message message)
|
Message |
Oort.OortExtension.rcvMeta(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.rcvMeta(Client from,
Message message)
|
protected void |
Seti.receive(Client from,
Client to,
Message msg)
|
Message |
Oort.OortExtension.send(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.send(Client from,
Message message)
|
Message |
Oort.OortExtension.sendMeta(Client from,
Message message)
|
Message |
Oort.RemoteOortClientExtension.sendMeta(Client from,
Message message)
|
Uses of Message in org.cometd.server |
---|
Classes in org.cometd.server that implement Message | |
---|---|
class |
MessageImpl
|
Methods in org.cometd.server that return Message | |
---|---|
protected Message |
AbstractBayeux.extendRcv(ClientImpl from,
Message message)
|
protected Message |
AbstractBayeux.extendRcvMeta(ClientImpl from,
Message message)
|
protected Message |
AbstractBayeux.extendSendBayeux(Client from,
Message message)
|
Message |
AbstractBayeux.extendSendClient(Client from,
ClientImpl to,
Message message)
|
Message |
AbstractBayeux.extendSendMeta(ClientImpl from,
Message message)
|
Message |
MessageImpl.getAssociated()
|
protected Message[] |
AbstractCometdServlet.getMessages(javax.servlet.http.HttpServletRequest request)
|
Message |
Transport.getMetaConnectReply()
|
Message |
AbstractTransport.getMetaConnectReply()
|
Message[] |
MessagePool.parse(java.io.Reader reader)
|
Message[] |
MessagePool.parse(java.lang.String s)
|
Methods in org.cometd.server that return types with arguments of type Message | |
---|---|
java.util.Queue<Message> |
ClientImpl.getQueue()
|
java.util.List<Message> |
ClientImpl.takeMessages()
|
Methods in org.cometd.server with parameters of type Message | |
---|---|
boolean |
AbstractBayeux.DefaultPolicy.canCreate(Client client,
java.lang.String channel,
Message message)
|
boolean |
AbstractBayeux.DefaultPolicy.canHandshake(Message message)
|
boolean |
AbstractBayeux.DefaultPolicy.canPublish(Client client,
java.lang.String channel,
Message message)
|
boolean |
AbstractBayeux.DefaultPolicy.canSubscribe(Client client,
java.lang.String channel,
Message message)
|
protected void |
ChannelImpl.doDelivery(ChannelId to,
Client from,
Message msg)
|
protected void |
ClientImpl.doDelivery(Client from,
Message msg)
|
protected Message |
AbstractBayeux.extendRcv(ClientImpl from,
Message message)
|
protected Message |
AbstractBayeux.extendRcvMeta(ClientImpl from,
Message message)
|
protected Message |
AbstractBayeux.extendSendBayeux(Client from,
Message message)
|
Message |
AbstractBayeux.extendSendClient(Client from,
ClientImpl to,
Message message)
|
Message |
AbstractBayeux.extendSendMeta(ClientImpl from,
Message message)
|
java.lang.String |
AbstractBayeux.handle(ClientImpl client,
Transport transport,
Message message)
Handle a Bayeux message. |
void |
AbstractBayeux.ConnectHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.DisconnectHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.HandshakeHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.PublishHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.MetaPublishHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.SubscribeHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.UnsubscribeHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
void |
AbstractBayeux.PingHandler.handle(ClientImpl client,
Transport transport,
Message message)
|
MessageImpl |
MessagePool.newMessage(Message associated)
|
void |
Transport.send(Message message)
|
void |
JSONPTransport.send(Message message)
|
void |
JSONTransport.send(Message message)
|
void |
MessageImpl.setAssociated(Message associated)
|
void |
Transport.setMetaConnectReply(Message reply)
|
void |
AbstractTransport.setMetaConnectReply(Message reply)
|
Method parameters in org.cometd.server with type arguments of type Message | |
---|---|
void |
MessagePool.parseTo(java.lang.String fodder,
java.util.List<Message> messages)
|
void |
ClientImpl.returnMessages(java.util.List<Message> messages)
|
Uses of Message in org.cometd.server.ext |
---|
Methods in org.cometd.server.ext that return Message | |
---|---|
Message |
AcknowledgedMessagesExtension.rcv(Client from,
Message message)
|
Message |
TimestampExtension.rcv(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.rcv(Client from,
Message message)
|
Message |
TimesyncExtension.rcv(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.rcvMeta(Client from,
Message message)
|
Message |
TimestampExtension.rcvMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.rcvMeta(Client from,
Message message)
Handle received meta messages. |
Message |
TimesyncExtension.rcvMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.send(Client from,
Message message)
|
Message |
TimestampExtension.send(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.send(Client from,
Message message)
|
Message |
TimesyncExtension.send(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.sendMeta(Client from,
Message message)
|
Message |
TimestampExtension.sendMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.sendMeta(Client from,
Message message)
|
Message |
TimesyncExtension.sendMeta(Client from,
Message message)
|
Methods in org.cometd.server.ext with parameters of type Message | |
---|---|
Message |
AcknowledgedMessagesExtension.rcv(Client from,
Message message)
|
Message |
TimestampExtension.rcv(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.rcv(Client from,
Message message)
|
Message |
TimesyncExtension.rcv(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.rcvMeta(Client from,
Message message)
|
Message |
TimestampExtension.rcvMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.rcvMeta(Client from,
Message message)
Handle received meta messages. |
Message |
TimesyncExtension.rcvMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.send(Client from,
Message message)
|
Message |
TimestampExtension.send(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.send(Client from,
Message message)
|
Message |
TimesyncExtension.send(Client from,
Message message)
|
Message |
AcknowledgedMessagesExtension.sendMeta(Client from,
Message message)
|
Message |
TimestampExtension.sendMeta(Client from,
Message message)
|
Message |
AcknowledgedMessagesClientExtension.sendMeta(Client from,
Message message)
|
Message |
TimesyncExtension.sendMeta(Client from,
Message message)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |