Package org.apache.sandesha2.storage.beans

Examples of org.apache.sandesha2.storage.beans.RMSBean

99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
            assertTrue(tmp.getCreateSeqMsgID().equals("CreateSeqMsgId1"));
        }
    }

    public void testInsert() throws SandeshaStorageException{
      RMSBean createSeqBean = new RMSBean ();
      createSeqBean.setInternalSequenceID("TmpSeqId4");
      createSeqBean.setCreateSeqMsgID("CreateSeqMsgId4");
      createSeqBean.setSequenceID("SeqId4");
        mgr.insert(createSeqBean);
        RMSBean tmpbean = mgr.retrieve("CreateSeqMsgId4");
        assertTrue(tmpbean.getCreateSeqMsgID().equals("CreateSeqMsgId4"));
        assertTrue(tmpbean.getSequenceID().equals("SeqId4"));
        assertTrue(tmpbean.getInternalSequenceID().equals("TmpSeqId4"));
    }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
125
126

    public void testRetrieve() throws SandeshaStorageException{
        assertNull(mgr.retrieve("CreateSeqMsgId5"));

      RMSBean createSeqBean = new RMSBean ();
      createSeqBean.setInternalSequenceID("TmpSeqId5");
      createSeqBean.setCreateSeqMsgID("CreateSeqMsgId5");
      createSeqBean.setSequenceID("SeqId5");
        mgr.insert(createSeqBean);
        RMSBean tmp = mgr.retrieve("CreateSeqMsgId5");
        assertTrue(tmp.getCreateSeqMsgID().equals("CreateSeqMsgId5"));
    }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
56
57
58
      String sequenceID = SandeshaUtil.getSequenceIDFromRMMessage(rmMsg);

      if (sequenceID != null) {
        String rmVersionOfSequence = null;

        RMSBean rmsBean = SandeshaUtil.getRMSBeanFromSequenceId(
            storageManager, sequenceID);
        if (rmsBean != null)
          rmVersionOfSequence = rmsBean.getRMVersion();
        else {
          RMDBean rmdBean = SandeshaUtil.getRMDBeanFromSequenceId(
              storageManager, sequenceID);
          if (rmdBean != null)
            rmVersionOfSequence = rmdBean.getRMVersion();
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
      if (createTransaction)
        reportTransaction = storageManager.getTransaction();

      sequenceReport.setInternalSequenceID(internalSequenceID);

      RMSBean createSeqFindBean = new RMSBean();
      createSeqFindBean.setInternalSequenceID(internalSequenceID);

      RMSBean rMSBean = createSeqMgr.findUnique(createSeqFindBean);

      // if data not is available sequence has to be terminated or
      // timedOut.
      if (rMSBean != null && rMSBean.isTerminated()) {

        // check weather this is an terminated sequence.
        sequenceReport.setSequenceStatus(SequenceReport.SEQUENCE_STATUS_TERMINATED);

        fillOutgoingSequenceInfo(sequenceReport, rMSBean, storageManager);

        return sequenceReport;

      } else if (rMSBean != null && rMSBean.isTimedOut()) {

        sequenceReport.setSequenceStatus(SequenceReport.SEQUENCE_STATUS_TIMED_OUT);
       
        fillOutgoingSequenceInfo(sequenceReport, rMSBean, storageManager);

        return sequenceReport;
       
      } else if (rMSBean == null) {

        // sequence must hv been timed out before establishing. No other
        // posibility I can think of.
        // this does not get recorded since there is no key (which is
        // normally the sequenceID) to store it.

        // so, setting the sequence status to INITIAL
        sequenceReport.setSequenceStatus(SequenceReport.SEQUENCE_STATUS_INITIAL);

        // returning the current sequence report.
        return sequenceReport;
      }

      String outSequenceID = rMSBean.getSequenceID();
      if (outSequenceID == null) {
        sequenceReport.setInternalSequenceID(internalSequenceID);
        sequenceReport.setSequenceStatus(SequenceReport.SEQUENCE_STATUS_INITIAL);
        sequenceReport.setSequenceDirection(SequenceReport.SEQUENCE_DIRECTION_OUT);
        if(rMSBean.getSecurityTokenData() != null) sequenceReport.setSecureSequence(true);

        return sequenceReport;
      }

      sequenceReport.setSequenceStatus(SequenceReport.SEQUENCE_STATUS_ESTABLISHED);
View Full Code Here
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
      reportTransaction = storageManager.getTransaction();

      List rmsBeans = storageManager.getRMSBeanMgr().find(null);
      Iterator iterator = rmsBeans.iterator();
      while (iterator.hasNext()) {
        RMSBean bean = (RMSBean) iterator.next();
        String sequenceID = bean.getSequenceID();
        sandeshaReport.addToOutgoingSequenceList(sequenceID);
        sandeshaReport.addToOutgoingInternalSequenceMap(sequenceID, bean.getInternalSequenceID());

        SequenceReport report = getOutgoingSequenceReport(bean.getInternalSequenceID(), configurationContext);

        sandeshaReport.addToNoOfCompletedMessagesMap(sequenceID, report.getCompletedMessages().size());
        sandeshaReport.addToSequenceStatusMap(sequenceID, report.getSequenceStatus());
      }
View Full Code Here
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
    Transaction tran = null;
   
    try {
      tran = storageManager.getTransaction();
     
      RMSBean rmsBean = SandeshaUtil.getRMSBeanFromInternalSequenceId(storageManager, internalSequenceId);
      //see if the sequence is terminated
      boolean terminatedSequence = false;
      if (rmsBean != null && rmsBean.isTerminated())
        terminatedSequence = true;
 
      //see if the sequence is timed out
      if(rmsBean != null && rmsBean.isTimedOut()){
        terminatedSequence = true;
      }
 
      if (terminatedSequence) {   
        // Delete the rmsBean
        storageManager.getRMSBeanMgr().delete(rmsBean.getCreateSeqMsgID());
      }
     
      if(tran != null && tran.isActive()) tran.commit();
      tran = null;
   
View Full Code Here
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
    Exception resultException = null;
   
    try
    {
      transaction = storageManager.getTransaction();
      RMSBean bean = SandeshaUtil.getRMSBeanFromInternalSequenceId(storageManager, internalSequenceId);
     
      if (bean != null) {           
        resultException = bean.getLastSendError();
      }
    }
    finally
    {
      // Commit the tran whatever happened
View Full Code Here
1359
1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
1372
    try
    {
      transaction = storageManager.getTransaction();
     
      RMSBean bean = SandeshaUtil.getRMSBeanFromInternalSequenceId(storageManager, internalSequenceId);
     
      if (bean != null) {           
        resultTime = bean.getLastSendErrorTimestamp();
      }
    }
    finally
    {
      // commit the transaction as it was only a retrieve
View Full Code Here
1413
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
    // Get the RMSBean for this sequence.
    Transaction transaction = null;
   
    try {
      transaction = storageManager.getTransaction();
      RMSBean rmsBean = SandeshaUtil.getRMSBeanFromInternalSequenceId(storageManager, internalSequenceID);
      if (rmsBean.getSoapVersion() == Sandesha2Constants.SOAPVersion.v1_2)
        soapNamespaceURI = SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI;
    } finally {
      if(transaction != null) transaction.commit();
    }
   
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
         
          TerminateSequence terminateSequence = (TerminateSequence) rmMsgCtx
              .getMessagePart(Sandesha2Constants.MessageParts.TERMINATE_SEQ);
          String sequenceID = terminateSequence.getIdentifier().getIdentifier();
 
          RMSBean rmsBean = SandeshaUtil.getRMSBeanFromSequenceId(storageManager, sequenceID);
          TerminateManager.terminateSendingSide(rmsBean, storageManager);
         
          if(transaction != null && transaction.isActive()) transaction.commit();
          transaction = null;
        } finally {
View Full Code Here
TOP

Related Classes of org.apache.sandesha2.storage.beans.RMSBean

  • org.apache.axis2.addressing.EndpointReference
  • org.apache.axis2.AxisFault
  • org.apache.axis2.client.MessageSender
  • org.apache.axis2.client.Options
  • org.apache.axis2.context.AbstractContext
  • org.apache.axis2.context.ConfigurationContext
  • org.apache.axis2.context.MessageContext
  • org.apache.axis2.context.OperationContext
  • org.apache.axis2.context.ServiceContext
  • org.apache.axis2.description.AxisOperation
    • 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.