Package org.serviceconnector.scmp

Examples of org.serviceconnector.scmp.SCMPVersion

82
83
84
85
86
87
88
89
90
91
92
    SCMPMessage reqMessage = this.request.getMessage();
    String sid = reqMessage.getSessionId();
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    String serviceName = reqMessage.getServiceName();
    SCMPMessage fault = null;
    SCMPVersion scmpVersion = reqMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT,
          "Operation timeout expired on SC csc abort subscription sid=" + sid);
    } else if (ex instanceof IOException) {
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
  @Override
  public void receive(Exception ex) {
    String sid = this.requestMessage.getSessionId();
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    SCMPMessage fault = null;
    SCMPVersion scmpVersion = this.requestMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT, "Operation timeout expired on SC sid=" + sid);
    } else if (ex instanceof IOException) {
      fault = new SCMPMessageFault(scmpVersion, SCMPError.CONNECTION_EXCEPTION, "broken connection to server sid=" + sid);
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
  public void receive(Exception ex) {
    SCMPMessage reqMessage = this.request.getMessage();
    String sid = reqMessage.getSessionId();
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    SCMPMessage fault = null;
    SCMPVersion scmpVersion = reqMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT, "Operation timeout expired on SC sid=" + sid);
    } else if (ex instanceof IOException) {
      fault = new SCMPMessageFault(scmpVersion, SCMPError.CONNECTION_EXCEPTION, "broken connection on SC sid=" + sid);
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
    SCMPMessage reqMessage = this.request.getMessage();
    String sid = reqMessage.getSessionId();
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    String serviceName = reqMessage.getServiceName();
    IStatefulServer server = this.cascSubscription.getServer();
    SCMPVersion scmpVersion = reqMessage.getSCMPVersion();

    if (reqMessage.getHeader(SCMPHeaderAttributeKey.CASCADED_MASK) == null) {
      // free server from subscription if cascaded SC unsubscribes himself
      server.removeSession(this.cascSubscription);
    }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    // free server from session
    server.removeSession(session);
    SCMPMessage fault = null;
    String serviceName = reqMessage.getServiceName();
    SCMPVersion scmpVersion = reqMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT,
          "Operation timeout expired on SC delete session sid=" + sid);
    } else if (ex instanceof IOException) {
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    SCMPMessage reqMessage = this.request.getMessage();
    String sid = reqMessage.getSessionId();
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    server.removeSession(session);
    SCMPMessage fault = null;
    SCMPVersion scmpVersion = reqMessage.getSCMPVersion();
    String serviceName = reqMessage.getServiceName();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT,
          "Operation timeout expired on SC create session sid=" + sid);
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
  /** {@inheritDoc} */
  @Override
  public void receive(Exception ex) {
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    SCMPMessage fault = null;
    SCMPVersion scmpVersion = this.requestMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMPVersion request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT, "Operation timeout expired on SC sid="
          + this.sid);
    } else if (ex instanceof IOException) {
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
    LOGGER.warn("receive exception sid=" + sid + " " + ex.toString());
    // creation failed remove from server
    this.tempSubscription.getServer().removeSession(tempSubscription);
    SCMPMessage fault = null;
    String serviceName = this.reqMessage.getServiceName();
    SCMPVersion scmpVersion = this.reqMessage.getSCMPVersion();
    if (ex instanceof IdleTimeoutException) {
      // operation timeout handling - SCMP Version request
      fault = new SCMPMessageFault(scmpVersion, SCMPError.OPERATION_TIMEOUT,
          "Operation timeout expired on SC cln subscribe sid=" + sid);
    } else if (ex instanceof IOException) {
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
    this.readBufferFromStream(is, headline);

    byte[] version = new byte[Constants.SCMP_VERSION_LENGTH_IN_HEADLINE];
    this.readBufferFromStream(is, version);
    SCMPVersion.CURRENT.isSupported(version);
    SCMPVersion receivedVersion = SCMPVersion.getSCMPVersionByByteArray(version);
    is.skip(1); // read LF

    SCMPMessage scmpMsg = null;
    // evaluating header key and creating corresponding SCMP type
    SCMPHeaderKey headerKey = SCMPHeaderKey.getKeyByHeadline(headline);
View Full Code Here
TOP

Related Classes of org.serviceconnector.scmp.SCMPVersion

  • org.serviceconnector.cmd.casc.ClnExecuteCommandCascCallback
  • org.serviceconnector.cmd.casc.CommandCascCallback
  • org.serviceconnector.cmd.casc.CscAbortSubscriptionCommandCallback
  • org.serviceconnector.cmd.casc.CscUnsubscribeCommandCallback
  • org.serviceconnector.cmd.sc.CreateSessionCommandCallback
  • org.serviceconnector.cmd.sc.DeleteSessionCommandCallback
  • org.serviceconnector.cmd.sc.ExecuteCommandCallback
  • org.serviceconnector.cmd.sc.SubscribeCommandCallback
  • org.serviceconnector.net.MessageEncoderDecoderAdapter
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.