Module org.neo4j.bolt.connection.netty

Package org.neo4j.bolt.connection.netty.impl.async.inbound

Class InboundMessageDispatcher

java.lang.Object

org.neo4j.bolt.connection.netty.impl.async.inbound.InboundMessageDispatcher

All Implemented Interfaces:

ResponseMessageHandler

public class InboundMessageDispatcher
extends Object
implements ResponseMessageHandler

Constructor Summary

Constructors

Constructor	Description
InboundMessageDispatcher(io.netty.channel.Channel channel, LoggingProvider logging)

Method Summary

Modifier and Type	Method	Description
void	enqueue(ResponseHandler handler)
boolean	fatalErrorOccurred()
void	handleChannelError(Throwable error)
void	handleChannelInactive(Throwable cause)
void	handleFailureMessage(GqlError gqlError)
void	handleIgnoredMessage()
void	handleRecordMessage(Value[] fields)
void	handleSuccessMessage(Map<String,Value> meta)
int	queuedHandlersCount()
void	setBeforeLastHandlerHook(Runnable beforeLastHandlerHook)

Methods inherited from class java.lang.Object

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

Constructor Details

InboundMessageDispatcher

public InboundMessageDispatcher(io.netty.channel.Channel channel,
 LoggingProvider logging)

Method Details

enqueue

public void enqueue(ResponseHandler handler)

setBeforeLastHandlerHook

public void setBeforeLastHandlerHook(Runnable beforeLastHandlerHook)

queuedHandlersCount

public int queuedHandlersCount()

handleSuccessMessage

public void handleSuccessMessage(Map<String,Value> meta)

Specified by:

handleSuccessMessage in interface ResponseMessageHandler

handleRecordMessage

public void handleRecordMessage(Value[] fields)

Specified by:

handleRecordMessage in interface ResponseMessageHandler

handleFailureMessage

public void handleFailureMessage(GqlError gqlError)

Specified by:

handleFailureMessage in interface ResponseMessageHandler

handleIgnoredMessage

public void handleIgnoredMessage()

Specified by:

handleIgnoredMessage in interface ResponseMessageHandler

handleChannelInactive

public void handleChannelInactive(Throwable cause)

handleChannelError

public void handleChannelError(Throwable error)

fatalErrorOccurred

public boolean fatalErrorOccurred()