Package org.serviceconnector.scmp

Examples of org.serviceconnector.scmp.SCMPKeepAlive

406
407
408
409
410
411
412
413
414
415
416
        }
      }
      this.usedConnections.add(connection);
    }
    // send a keep alive message
    SCMPKeepAlive keepAliveMessage = new SCMPKeepAlive();
    connection.incrementNrOfIdles();
    try {
      ConnectionPoolCallback callback = new ConnectionPoolCallback(true);
      connection.send(keepAliveMessage, callback);
      SCMPMessage reply = callback.getMessageSync(this.keepAliveOTIMillis);
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    // evaluating header key and creating corresponding SCMP type
    SCMPHeaderKey headerKey = SCMPHeaderKey.getKeyByHeadline(headline);
    switch (headerKey) {
    case KRS:
    case KRQ:
      scmpMsg = new SCMPKeepAlive();
      return scmpMsg;
    case PRQ:
    case PRS:
      // no poll request
      scmpMsg = new SCMPPart(false);
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
  /** {@inheritDoc} */
  @Override
  public void encode(OutputStream os, Object obj) throws Exception {
    OutputStreamWriter osw = new OutputStreamWriter(os, Constants.SC_CHARACTER_SET);
    BufferedWriter bw = new BufferedWriter(osw);
    SCMPKeepAlive keepAlive = (SCMPKeepAlive) obj;
    if (keepAlive.isReply()) {
      SCMPHeaderKey headerKey = SCMPHeaderKey.KRS;
      writeHeadLine(bw, headerKey, 0, 0);
    } else {
      SCMPHeaderKey headerKey = SCMPHeaderKey.KRQ;
      writeHeadLine(bw, headerKey, 0, 0);
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
    String requestString = TestUtil.getSCMPString(headKey, null, null);

    byte[] buffer = requestString.getBytes();
    InputStream is = new ByteArrayInputStream(buffer);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive(SCMPVersion.CURRENT));

    SCMPMessage message = null;
    try {
      message = (SCMPMessage) coder.decode(is);
    } catch (Exception e) {
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    this.headKey = SCMPHeaderKey.KRS;
    String requestString = headKey.name() + " 0000000 00000 1.0\n";

    byte[] buffer = requestString.getBytes();
    InputStream is = new ByteArrayInputStream(buffer);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive(SCMPVersion.CURRENT));

    SCMPMessage message = null;
    try {
      message = (SCMPMessage) coder.decode(is);
    } catch (Exception e) {
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
105
   * Expectation: passes
   */
  @Test
  public void t10_EncodeKRQTest() {
    this.headKey = SCMPHeaderKey.KRQ;
    this.encodeScmp = new SCMPKeepAlive(SCMPVersion.CURRENT);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive(SCMPVersion.CURRENT));

    String expectedString = this.headKey.name() + " 0000000 00000 " + SCMPVersion.CURRENT + "\n";

    OutputStream os = new ByteArrayOutputStream();
    try {
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
126
   * Expectation: passes
   */
  @Test
  public void t11_EncodeKRSTest() {
    this.headKey = SCMPHeaderKey.KRS;
    this.encodeScmp = new SCMPKeepAlive(SCMPVersion.CURRENT);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive(SCMPVersion.CURRENT));

    String expectedString = this.headKey.name() + " 0000000 00000 " + SCMPVersion.CURRENT + "\n";

    OutputStream os = new ByteArrayOutputStream();
    try {
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
    String requestString = TestUtil.getSCMPString(headKey, null, null);

    byte[] buffer = requestString.getBytes();
    InputStream is = new ByteArrayInputStream(buffer);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive());

    SCMPMessage message = null;
    try {
      message = (SCMPMessage) coder.decode(is);
    } catch (Exception e) {
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
    this.headKey = SCMPHeaderKey.KRS;
    String requestString = headKey.name() + " 0000000 00000 1.0\n";

    byte[] buffer = requestString.getBytes();
    InputStream is = new ByteArrayInputStream(buffer);
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive());

    SCMPMessage message = null;
    try {
      message = (SCMPMessage) coder.decode(is);
    } catch (Exception e) {
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
105
   * Expectation: passes
   */
  @Test
  public void t10_EncodeKRQTest() {
    this.headKey = SCMPHeaderKey.KRQ;
    this.encodeScmp = new SCMPKeepAlive();
    IEncoderDecoder coder = coderFactory.createEncoderDecoder(new SCMPKeepAlive());

    String expectedString = this.headKey.name() + " 0000000 00000 " + SCMPVersion.CURRENT + "\n";

    OutputStream os = new ByteArrayOutputStream();
    try {
View Full Code Here
TOP

Related Classes of org.serviceconnector.scmp.SCMPKeepAlive

  • org.serviceconnector.net.connection.ConnectionPool
  • org.serviceconnector.net.KeepAliveMessageEncoderDecoder
  • org.serviceconnector.net.MessageEncoderDecoderAdapter
  • org.serviceconnector.test.unit.KeepAliveMessageEncoderDecoderTest
    • 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.