Class Connection


  • public class Connection
    extends java.lang.Object
    • Field Detail

      • transport

        private final Transport transport
      • objects

        private final java.util.Map<java.lang.String,​ChannelOwner> objects
      • isRemote

        final boolean isRemote
      • lastId

        private int lastId
      • callbacks

        private final java.util.Map<java.lang.Integer,​WaitableResult<com.google.gson.JsonElement>> callbacks
      • apiName

        private java.lang.String apiName
      • isLogging

        private static final boolean isLogging
      • env

        final java.util.Map<java.lang.String,​java.lang.String> env
      • tracingCount

        private int tracingCount
    • Constructor Detail

      • Connection

        Connection​(Transport pipe,
                   java.util.Map<java.lang.String,​java.lang.String> env,
                   LocalUtils localUtils)
      • Connection

        Connection​(Transport transport,
                   java.util.Map<java.lang.String,​java.lang.String> env)
      • Connection

        private Connection​(Transport transport,
                           java.util.Map<java.lang.String,​java.lang.String> env,
                           boolean isRemote)
    • Method Detail

      • setIsTracing

        void setIsTracing​(boolean tracing)
      • setApiName

        java.lang.String setApiName​(java.lang.String name)
      • close

        void close()
            throws java.io.IOException
        Throws:
        java.io.IOException
      • sendMessage

        public com.google.gson.JsonElement sendMessage​(java.lang.String guid,
                                                       java.lang.String method,
                                                       com.google.gson.JsonObject params)
      • sendMessageAsync

        public WaitableResult<com.google.gson.JsonElement> sendMessageAsync​(java.lang.String guid,
                                                                            java.lang.String method,
                                                                            com.google.gson.JsonObject params)
      • internalSendMessage

        private WaitableResult<com.google.gson.JsonElement> internalSendMessage​(java.lang.String guid,
                                                                                java.lang.String method,
                                                                                com.google.gson.JsonObject params,
                                                                                boolean sendStack)
      • getExistingObject

        public <T> T getExistingObject​(java.lang.String guid)
      • registerObject

        void registerObject​(java.lang.String guid,
                            ChannelOwner object)
      • unregisterObject

        void unregisterObject​(java.lang.String guid)
      • processOneMessage

        void processOneMessage()
      • dispatch

        private void dispatch​(Message message)
      • createRemoteObject

        private ChannelOwner createRemoteObject​(java.lang.String parentGuid,
                                                com.google.gson.JsonObject params)