public final class MapWireHandler<K,V> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MapWireHandler.EventId |
static class |
MapWireHandler.Params |
Constructor and Description |
---|
MapWireHandler(@NotNull software.chronicle.datagrid.internal.server.CspManager cspManager) |
Modifier and Type | Method and Description |
---|---|
static void |
enrichThrowableMessage(Throwable t,
String readingYaml) |
void |
onEndOfConnection()
called when the connection is closed
|
void |
process(@NotNull net.openhft.chronicle.wire.WireIn in,
@NotNull net.openhft.chronicle.wire.WireOut out,
@NotNull MapView map,
long tid,
@NotNull WireAdapter wireAdapter,
@NotNull RequestContext requestContext) |
protected void |
unregisterAll()
called when the connection is closed
|
public MapWireHandler(@NotNull @NotNull software.chronicle.datagrid.internal.server.CspManager cspManager)
public void process(@NotNull @NotNull net.openhft.chronicle.wire.WireIn in, @NotNull @NotNull net.openhft.chronicle.wire.WireOut out, @NotNull @NotNull MapView map, long tid, @NotNull @NotNull WireAdapter wireAdapter, @NotNull @NotNull RequestContext requestContext)
in
- the data the has come in from networkout
- the data that is going out to networkmap
- the map that is being processedtid
- the transaction id of the eventwireAdapter
- adapts keys and values to and from wirerequestContext
- the uri of the eventpublic void onEndOfConnection()
protected void unregisterAll()
Copyright © 2021. All rights reserved.