Package se.laz.casual.network.outbound

Class NettyNetworkConnection

java.lang.Object
se.laz.casual.network.outbound.NettyNetworkConnection
All Implemented Interfaces:
se.laz.casual.api.conversation.ConversationClose, se.laz.casual.internal.network.NetworkConnection, CasualOutboundMessageListener
public class NettyNetworkConnection extends Object implements se.laz.casual.internal.network.NetworkConnection, se.laz.casual.api.conversation.ConversationClose, CasualOutboundMessageListener

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addConnectionObserver(se.laz.casual.jca.ConnectionObserver observer)
     
    void
    addListener(NetworkListener listener)
     
    void
    close()
     
    void
    close(UUID conversationalCorrId)
     
    boolean
    equals(Object o)
     
    se.laz.casual.api.conversation.ConversationClose
    getConversationClose()
     
    se.laz.casual.jca.DomainId
    getDomainId()
     
    se.laz.casual.network.ProtocolVersion
    getProtocolVersion()
     
    <T extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable>
    void
    handleMessage(se.laz.casual.api.network.protocol.messages.CasualNWMessage<T> message)
     
    int
    hashCode()
     
    boolean
    isActive()
     
    boolean
    isInterestedIn(se.laz.casual.api.network.protocol.messages.CasualNWMessageType type)
     
    static se.laz.casual.internal.network.NetworkConnection
    of(NettyConnectionInformation ci, NetworkListener networkListener)
     
    CompletableFuture<se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request>>
    receive(UUID corrid)
     
    <T extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable, X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable>
    CompletableFuture<se.laz.casual.api.network.protocol.messages.CasualNWMessage<T>>
    request(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
     
    <X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable>
    void
    requestNoReply(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
     
    <X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable>
    void
    send(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
     
    String
    toString()
     

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Method Details

    • of

      public static se.laz.casual.internal.network.NetworkConnection of(NettyConnectionInformation ci, NetworkListener networkListener)

    • getProtocolVersion

      public se.laz.casual.network.ProtocolVersion getProtocolVersion()

    • request

      public <T extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable, X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable> CompletableFuture<se.laz.casual.api.network.protocol.messages.CasualNWMessage<T>> request(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
      Specified by:
      request in interface se.laz.casual.internal.network.NetworkConnection

    • requestNoReply

      public <X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable> void requestNoReply(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
      Specified by:
      requestNoReply in interface se.laz.casual.internal.network.NetworkConnection

    • send

      public <X extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable> void send(se.laz.casual.api.network.protocol.messages.CasualNWMessage<X> message)
      Specified by:
      send in interface se.laz.casual.internal.network.NetworkConnection

    • receive

      public CompletableFuture<se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request>> receive(UUID corrid)
      Specified by:
      receive in interface se.laz.casual.internal.network.NetworkConnection

    • close

      public void close()
      Specified by:
      close in interface se.laz.casual.internal.network.NetworkConnection

    • isActive

      public boolean isActive()
      Specified by:
      isActive in interface se.laz.casual.internal.network.NetworkConnection

    • getDomainId

      public se.laz.casual.jca.DomainId getDomainId()
      Specified by:
      getDomainId in interface se.laz.casual.internal.network.NetworkConnection

    • addConnectionObserver

      public void addConnectionObserver(se.laz.casual.jca.ConnectionObserver observer)
      Specified by:
      addConnectionObserver in interface se.laz.casual.internal.network.NetworkConnection

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getConversationClose

      public se.laz.casual.api.conversation.ConversationClose getConversationClose()
      Specified by:
      getConversationClose in interface se.laz.casual.internal.network.NetworkConnection

    • close

      public void close(UUID conversationalCorrId)
      Specified by:
      close in interface se.laz.casual.api.conversation.ConversationClose

    • addListener

      public void addListener(NetworkListener listener)

    • isInterestedIn

      public boolean isInterestedIn(se.laz.casual.api.network.protocol.messages.CasualNWMessageType type)
      Specified by:
      isInterestedIn in interface CasualOutboundMessageListener

    • handleMessage

      public <T extends se.laz.casual.api.network.protocol.messages.CasualNetworkTransmittable> void handleMessage(se.laz.casual.api.network.protocol.messages.CasualNWMessage<T> message)
      Specified by:
      handleMessage in interface CasualOutboundMessageListener