| Package | Description |
|---|---|
| de.hybris.platform.cluster | |
| de.hybris.platform.cluster.jgroups | |
| de.hybris.platform.cluster.legacy | |
| de.hybris.platform.cluster.udp |
| Modifier and Type | Method and Description |
|---|---|
RawMessage |
RawMessage.join(java.util.Collection<RawMessage> messageparts)
Joins the current RawMessage (this) with the given list of RawMessages into a new joined RawMessage.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<RawMessage> |
RawMessage.split(int packetSize)
Splits the current RawMessage (this) into several RawMessages which are the same size or less (including the
header) as the given packet size.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
BroadcastService.accept(RawMessage message)
Returns
true if the given message is by the current broadcast service accepted |
boolean |
DefaultBroadcastService.accept(RawMessage message)
Determines whether or not a specific message is being accepted.
|
void |
DefaultBroadcastService.addTransportData(RawMessage message) |
protected boolean |
DefaultBroadcastService.isDuplicateMessage(RawMessage message) |
protected boolean |
DefaultBroadcastService.isLocal(RawMessage message) |
boolean |
RawMessage.matches(RawMessage other)
TODO apidoc
|
protected void |
AbstractBroadcastMethod.notifyMessgageReceived(RawMessage message) |
protected void |
InvalidationBroadcastHandler.processInvalidation(InvalidationBroadcastHandler.InvalidationEvent event,
RawMessage message) |
boolean |
BroadcastMessageListener.processMessage(RawMessage message) |
boolean |
PingBroadcastHandler.processMessage(RawMessage message) |
boolean |
DefaultBroadcastService.MethodBroadcastListener.processMessage(RawMessage message) |
boolean |
InvalidationBroadcastHandler.processMessage(RawMessage message) |
protected void |
DefaultBroadcastService.processMessageFromMethod(RawMessage message,
java.lang.String methodName) |
protected boolean |
PingBroadcastHandler.processPingMessage(RawMessage message) |
void |
BroadcastService.send(RawMessage message)
TODO apidoc
|
void |
BroadcastMethod.send(RawMessage message)
Sends a raw data message to all connected hybris platform nodes
|
void |
LoopBackBroadcastMethod.send(RawMessage message)
Directly sends message back to listeners.
|
void |
DefaultBroadcastService.send(RawMessage message) |
void |
DummyBroadcastMethod.send(RawMessage message) |
protected void |
DefaultBroadcastService.sendAsnychronously(DefaultBroadcastService.MethodWrapper methodWrapper,
RawMessage message,
Tenant currentTenant,
java.util.concurrent.ExecutorService executorService)
Sends a message using a executor service.
|
protected void |
DefaultBroadcastService.sendSynchronously(DefaultBroadcastService.MethodWrapper methodWrapper,
RawMessage message)
Sends a message synchronously.
|
| Modifier and Type | Method and Description |
|---|---|
RawMessage |
RawMessage.join(java.util.Collection<RawMessage> messageparts)
Joins the current RawMessage (this) with the given list of RawMessages into a new joined RawMessage.
|
| Constructor and Description |
|---|
RawMessage(RawMessage original,
int numberOfPackets,
int currentPacketNumber,
int offset,
int length)
Constructor used for message splitting.
|
| Modifier and Type | Method and Description |
|---|---|
void |
JGroupsBroadcastMethod.send(RawMessage message) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
LegacyBroadcastHandler.notifyMessageReceived(RawMessage message,
byte[] data) |
boolean |
LegacyBroadcastHandler.processMessage(RawMessage message) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
UnicastBroadcastMethod.accept(RawMessage msg) |
protected void |
UnicastBroadcastMethod.notifyMessgageReceived(RawMessage message) |
void |
UDPBroadcastMethod.send(RawMessage message)
Sends the given
RawMessage. |
void |
UnicastBroadcastMethod.send(RawMessage message)
Sends the given
RawMessage. |
protected void |
UDPRecorder.showStatus(java.net.DatagramPacket datagramPacket,
RawMessage message) |
protected void |
UDPSniffer.showStatus(java.net.DatagramPacket datagramPacket,
RawMessage msg)
parses the specified datagram packet
|
Copyright © 2018 SAP SE. All Rights Reserved.