software.chronicle.datagrid.internal.server

Class MapWireHandler<K,V>

java.lang.Object

software.chronicle.datagrid.internal.server.MapWireHandler<K,V>

public final class MapWireHandler<K,V>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MapWireHandler.EventId
static class	MapWireHandler.Params

Constructor Summary

Constructors

Constructor and Description
MapWireHandler(@NotNull software.chronicle.datagrid.internal.server.CspManager cspManager)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapWireHandler

public MapWireHandler(@NotNull
                      @NotNull software.chronicle.datagrid.internal.server.CspManager cspManager)

Method Detail

process

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)

Parameters:

in - the data the has come in from network

out - the data that is going out to network

map - the map that is being processed

tid - the transaction id of the event

wireAdapter - adapts keys and values to and from wire

requestContext - the uri of the event

enrichThrowableMessage

public static void enrichThrowableMessage(Throwable t,
                                          String readingYaml)

onEndOfConnection

public void onEndOfConnection()

called when the connection is closed

unregisterAll

protected void unregisterAll()

called when the connection is closed