public class NettySubscriber extends Object implements Subscriber<io.netty.channel.ChannelHandlerContext>
Constructor and Description |
---|
NettySubscriber(String clientId,
io.netty.channel.ChannelHandlerContext ctx) |
Modifier and Type | Method and Description |
---|---|
io.netty.channel.ChannelHandlerContext |
channel()
The channel that this subscriber uses to communicate.
|
String |
clientId()
The client identifier of this subscriber
|
boolean |
equals(Object o) |
int |
hashCode() |
void |
patched(PatchMessage<?> patchMessage)
Is called when this subscribers underlying document has been patched, allowing
it to handle the
PatchMessage . |
String |
toString() |
public NettySubscriber(String clientId, io.netty.channel.ChannelHandlerContext ctx)
public String clientId()
Subscriber
clientId
in interface Subscriber<io.netty.channel.ChannelHandlerContext>
String
the subscribers/clients identifierpublic io.netty.channel.ChannelHandlerContext channel()
Subscriber
This can be anything that the subscriber supports, for example it could be object representing a connection, or a simple String representing the communication channel.
channel
in interface Subscriber<io.netty.channel.ChannelHandlerContext>
T
the channel used to communicate.public void patched(PatchMessage<?> patchMessage)
Subscriber
PatchMessage
.patched
in interface Subscriber<io.netty.channel.ChannelHandlerContext>
patchMessage
- the result of patching this subscribers underying document.Copyright © 2015 JBoss by Red Hat. All Rights Reserved.