Index

A B C D E G H I J L N O P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

acceptOutboundMessage(Object) - Method in class se.laz.casual.network.CasualNWMessageEncoder

addListener(NetworkListener) - Method in class se.laz.casual.network.outbound.ErrorInformer

addListener(NetworkListener) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

asLogEntry(CasualNWMessage<X>) - Static method in class se.laz.casual.network.outbound.LogTool

AutoConnect - Class in se.laz.casual.network.inbound.reverse

AutoReconnect - Class in se.laz.casual.network.inbound.reverse

AutoReconnect(RepeatUntilSuccessTaskWork<ReverseInboundServer>) - Constructor for class se.laz.casual.network.inbound.reverse.AutoReconnect

B

BaseConnectionInformation - Class in se.laz.casual.network.outbound

BaseConnectionInformation(InetSocketAddress, ProtocolVersion, UUID, String, boolean) - Constructor for class se.laz.casual.network.outbound.BaseConnectionInformation

build() - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

build() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

build() - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

Builder() - Constructor for class se.laz.casual.network.inbound.ConnectionInformation.Builder

Builder() - Constructor for class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

Builder() - Constructor for class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

C

CasualDecoderException - Exception in se.laz.casual.network

CasualDecoderException(Throwable, UUID) - Constructor for exception se.laz.casual.network.CasualDecoderException

CasualMessageHandler - Class in se.laz.casual.network.inbound

CasualMessageHandler - Class in se.laz.casual.network.outbound

CasualNWMessageDecoder - Class in se.laz.casual.network

CasualNWMessageEncoder - Class in se.laz.casual.network

CasualServer - Class in se.laz.casual.network.inbound

Inbound casual server

CasualServer(Channel) - Constructor for class se.laz.casual.network.inbound.CasualServer

channelRead0(ChannelHandlerContext, CasualNWMessage<?>) - Method in class se.laz.casual.network.inbound.CasualMessageHandler

channelRead0(ChannelHandlerContext, CasualNWMessage<?>) - Method in class se.laz.casual.network.outbound.CasualMessageHandler

channelRead0(ChannelHandlerContext, CasualNWMessage<Request>) - Method in class se.laz.casual.network.outbound.ConversationMessageHandler

clear(UUID) - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

clear(UUID) - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

clearAllConversations() - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

clearAllConversations() - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

close() - Method in class se.laz.casual.network.inbound.CasualServer

close() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

close(UUID) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

complete(CasualNWMessage<T>) - Method in interface se.laz.casual.network.outbound.Correlator

complete(CasualNWMessage<T>) - Method in class se.laz.casual.network.outbound.CorrelatorImpl

completeAllExceptionally(Exception) - Method in interface se.laz.casual.network.outbound.Correlator

completeAllExceptionally(Exception) - Method in class se.laz.casual.network.outbound.CorrelatorImpl

completeExceptionally(List<UUID>, Exception) - Method in interface se.laz.casual.network.outbound.Correlator

completeExceptionally(List<UUID>, Exception) - Method in class se.laz.casual.network.outbound.CorrelatorImpl

ConnectionInformation - Class in se.laz.casual.network.inbound

ConnectionInformation.Builder - Class in se.laz.casual.network.inbound

ConversationMessageHandler - Class in se.laz.casual.network.outbound

ConversationMessageStorage - Interface in se.laz.casual.network.outbound

ConversationMessageStorageImpl - Class in se.laz.casual.network.outbound

Correlator - Interface in se.laz.casual.network.outbound

CorrelatorImpl - Class in se.laz.casual.network.outbound

create(InetSocketAddress, ProtocolVersion) - Static method in class se.laz.casual.network.outbound.NettyConnectionInformationCreator

createBuilder() - Static method in class se.laz.casual.network.inbound.ConnectionInformation

createBuilder() - Static method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

createBuilder() - Static method in class se.laz.casual.network.outbound.NettyConnectionInformation

D

decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class se.laz.casual.network.CasualNWMessageDecoder

disconnected(Exception) - Method in interface se.laz.casual.network.outbound.NetworkListener

E

encode(ChannelHandlerContext, CasualNWMessage<?>, ByteBuf) - Method in class se.laz.casual.network.CasualNWMessageEncoder

equals(Object) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundServerImpl

equals(Object) - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

equals(Object) - Method in class se.laz.casual.network.outbound.CorrelatorImpl

equals(Object) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation

equals(Object) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

ErrorInformer - Class in se.laz.casual.network.outbound

EventLoopFactory - Class in se.laz.casual.network.outbound

exceptionCaught(ChannelHandlerContext, Throwable) - Method in class se.laz.casual.network.inbound.ExceptionHandler

exceptionCaught(ChannelHandlerContext, Throwable) - Method in class se.laz.casual.network.outbound.ExceptionHandler

ExceptionHandler - Class in se.laz.casual.network.inbound

ExceptionHandler - Class in se.laz.casual.network.outbound

ExceptionHandler() - Constructor for class se.laz.casual.network.inbound.ExceptionHandler

G

getAddress() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getAddress() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundServerImpl

getAddress() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

getChannelClass() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getChannelClass() - Method in class se.laz.casual.network.outbound.NettyConnectionInformation

getConversationClose() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

getCorrelator() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getCorrelator() - Method in class se.laz.casual.network.outbound.NettyConnectionInformation

getCorrid() - Method in exception se.laz.casual.network.CasualDecoderException

getDomainId() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getDomainId() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

getDomainId() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

getDomainName() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getDomainName() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

getFactory() - Method in class se.laz.casual.network.inbound.ConnectionInformation

getFactory() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getInstance() - Static method in class se.laz.casual.network.outbound.EventLoopFactory

getManagedExecutorService() - Static method in class se.laz.casual.network.outbound.JEEConcurrencyFactory

Gets default managed executor service - on jboss On wls it will throw CasualResourceAdapterException unless a direct JNDI-name is configured

getPort() - Method in class se.laz.casual.network.inbound.ConnectionInformation

getProtocolVersion() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getProtocolVersion() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

getWorkManager() - Method in class se.laz.casual.network.inbound.ConnectionInformation

getWorkManager() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

getXaTerminator() - Method in class se.laz.casual.network.inbound.ConnectionInformation

getXaTerminator() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

H

hashCode() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundServerImpl

hashCode() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

hashCode() - Method in class se.laz.casual.network.outbound.CorrelatorImpl

hashCode() - Method in class se.laz.casual.network.outbound.NettyConnectionInformation

hashCode() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

I

inform() - Method in class se.laz.casual.network.outbound.ErrorInformer

isActive() - Method in class se.laz.casual.network.inbound.CasualServer

isActive() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

isEmpty() - Method in interface se.laz.casual.network.outbound.Correlator

isEmpty() - Method in class se.laz.casual.network.outbound.CorrelatorImpl

isLogHandlerEnabled() - Method in class se.laz.casual.network.inbound.ConnectionInformation

isLogHandlerEnabled() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

isLogHandlerEnabled() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

isUseEpoll() - Method in class se.laz.casual.network.inbound.ConnectionInformation

J

JEEConcurrencyFactory - Class in se.laz.casual.network.outbound

L

LogTool - Class in se.laz.casual.network.outbound

N

NettyConnectionInformation - Class in se.laz.casual.network.outbound

NettyConnectionInformation.Builder - Class in se.laz.casual.network.outbound

NettyConnectionInformationCreator - Class in se.laz.casual.network.outbound

NettyNetworkConnection - Class in se.laz.casual.network.outbound

NetworkErrorHandler - Class in se.laz.casual.network.outbound

NetworkListener - Interface in se.laz.casual.network.outbound

nextMessage(UUID) - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

nextMessage(UUID) - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

notifyListenerIfNotConnected(Channel) - Method in interface se.laz.casual.network.outbound.OnNetworkError

notifyListenersIfNotConnected(Channel, ErrorInformer) - Static method in class se.laz.casual.network.outbound.NetworkErrorHandler

numberOfConversations() - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

numberOfConversations() - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

O

of() - Static method in class se.laz.casual.network.CasualNWMessageDecoder

of() - Static method in class se.laz.casual.network.CasualNWMessageEncoder

of() - Static method in class se.laz.casual.network.inbound.ExceptionHandler

of() - Static method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

of() - Static method in class se.laz.casual.network.outbound.CorrelatorImpl

of(MessageEndpointFactory, XATerminator, WorkManager) - Static method in class se.laz.casual.network.inbound.CasualMessageHandler

of(CasualConnectionException) - Static method in class se.laz.casual.network.outbound.ErrorInformer

of(ConnectionInformation) - Static method in class se.laz.casual.network.inbound.CasualServer

of(ReverseInboundConnectionInformation, ReverseInboundConnectListener, ReverseInboundListener, Supplier<WorkManager>) - Static method in class se.laz.casual.network.inbound.reverse.AutoConnect

of(ReverseInboundConnectionInformation, ReverseInboundListener, Supplier<WorkManager>) - Static method in class se.laz.casual.network.inbound.reverse.AutoReconnect

of(ReverseInboundConnectionInformation, ReverseInboundListener, Supplier<WorkManager>) - Static method in class se.laz.casual.network.inbound.reverse.ReverseInboundServerImpl

of(ConversationMessageStorage) - Static method in class se.laz.casual.network.outbound.ConversationMessageHandler

of(Correlator) - Static method in class se.laz.casual.network.outbound.CasualMessageHandler

of(Correlator, OnNetworkError) - Static method in class se.laz.casual.network.outbound.ExceptionHandler

of(NettyConnectionInformation, NetworkListener) - Static method in class se.laz.casual.network.outbound.NettyNetworkConnection

OnNetworkError - Interface in se.laz.casual.network.outbound

P

put(UUID, CompletableFuture<?>) - Method in interface se.laz.casual.network.outbound.Correlator

put(UUID, CompletableFuture<?>) - Method in class se.laz.casual.network.outbound.CorrelatorImpl

put(UUID, CasualNWMessage<Request>) - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

put(UUID, CasualNWMessage<Request>) - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

R

receive(UUID) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

remove(UUID) - Static method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

request(CasualNWMessage<X>) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

ReverseInboundConnectionInformation - Class in se.laz.casual.network.inbound.reverse

ReverseInboundConnectionInformation.Builder - Class in se.laz.casual.network.inbound.reverse

ReverseInboundServerImpl - Class in se.laz.casual.network.inbound.reverse

Inbound server that connects and then acts exactly like CasualServer Note that we connect and then casual issues the domain connect request after which we act as if we were inbound all along.

S

se.laz.casual.network - package se.laz.casual.network

se.laz.casual.network.inbound - package se.laz.casual.network.inbound

se.laz.casual.network.inbound.reverse - package se.laz.casual.network.inbound.reverse

se.laz.casual.network.outbound - package se.laz.casual.network.outbound

send(CasualNWMessage<X>) - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

size(UUID) - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

size(UUID) - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

T

takeFirst(UUID) - Method in interface se.laz.casual.network.outbound.ConversationMessageStorage

Blocks until a message is available

takeFirst(UUID) - Method in class se.laz.casual.network.outbound.ConversationMessageStorageImpl

toString() - Method in class se.laz.casual.network.inbound.reverse.AutoConnect

toString() - Method in class se.laz.casual.network.inbound.reverse.AutoReconnect

toString() - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundServerImpl

toString() - Method in class se.laz.casual.network.outbound.BaseConnectionInformation

toString() - Method in class se.laz.casual.network.outbound.NettyConnectionInformation

toString() - Method in class se.laz.casual.network.outbound.NettyNetworkConnection

U

USE_LOG_HANDLER_ENV_NAME - Static variable in class se.laz.casual.network.inbound.ConnectionInformation

USE_LOG_HANDLER_ENV_NAME - Static variable in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation

USE_LOG_HANDLER_ENV_NAME - Static variable in class se.laz.casual.network.outbound.NettyConnectionInformation

W

withAddress(InetSocketAddress) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withAddress(InetSocketAddress) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withChannelClass(Class<? extends Channel>) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withChannelClass(Class<? extends Channel>) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withCorrelator(Correlator) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withCorrelator(Correlator) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withDomainId(UUID) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withDomainId(UUID) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withDomainName(String) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withDomainName(String) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withEnabledLogHandler(boolean) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withFactory(MessageEndpointFactory) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withFactory(MessageEndpointFactory) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withPort(int) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withProtocolVersion(ProtocolVersion) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withProtocolVersion(ProtocolVersion) - Method in class se.laz.casual.network.outbound.NettyConnectionInformation.Builder

withUseEpoll(boolean) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withWorkManager(WorkManager) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withWorkManager(WorkManager) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

withXaTerminator(XATerminator) - Method in class se.laz.casual.network.inbound.ConnectionInformation.Builder

withXaTerminator(XATerminator) - Method in class se.laz.casual.network.inbound.reverse.ReverseInboundConnectionInformation.Builder

A B C D E G H I J L N O P R S T U W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form