Examples of CoordinatorDetails

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

74
75
76
77
78
79
80
81
82
83
        InstanceIdentifier.setEndpointInstanceIdentifier(epr, instanceIdentifier);
        final AddressingContext addressingContext = AddressingContext.createRequestContext(epr, messageId) ;

        CoordinatorClient.getClient().sendPrepared(addressingContext, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasPrepared());
        // expect reply to address and identifier
        checkDetails(details, true, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

92
93
94
95
96
97
98
99
100
101
        InstanceIdentifier.setEndpointInstanceIdentifier(epr, instanceIdentifier);
        final AddressingContext addressingContext = AddressingContext.createRequestContext(epr, messageId) ;

        CoordinatorClient.getClient().sendAborted(addressingContext, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasAborted());
        // don't expect reply to address but do expect identifier
        checkDetails(details, false, messageId, instanceIdentifier);
   }
View Full Code Here

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

110
111
112
113
114
115
116
117
118
119
        InstanceIdentifier.setEndpointInstanceIdentifier(epr, instanceIdentifier);
        final AddressingContext addressingContext = AddressingContext.createRequestContext(epr, messageId) ;

        CoordinatorClient.getClient().sendReadOnly(addressingContext, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasReadOnly());
        // don't expect reply to address but do expect identifier
        checkDetails(details, false, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

128
129
130
131
132
133
134
135
136
137
        InstanceIdentifier.setEndpointInstanceIdentifier(epr, instanceIdentifier);
        final AddressingContext addressingContext = AddressingContext.createRequestContext(epr, messageId) ;

        CoordinatorClient.getClient().sendCommitted(addressingContext, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasCommitted());
        // don't expect reply to address but do expect identifier
        checkDetails(details, false, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

146
147
148
149
150
151
152
153
154
155
        InstanceIdentifier.setEndpointInstanceIdentifier(epr, instanceIdentifier);
        final AddressingContext addressingContext = AddressingContext.createRequestContext(epr, messageId) ;

        CoordinatorClient.getClient().sendReplay(addressingContext, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasReplay());
        // expect reply to address and identifier
        checkDetails(details, true, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

167
168
169
170
171
172
173
174
175
176
177
178
179
        // for this test we use the soap fault client to send a message where we have no valid instance identifier
        // we could also test the case where we have an instance identifier but it never gets exercised anyway!
        CoordinatorClient.getClient().sendSoapFault(addressingContext, soapFault, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertNotNull(details.hasSoapFault());
        assertEquals(details.hasSoapFault().getSoapFaultType(), soapFault.getSoapFaultType());
        assertEquals(details.hasSoapFault().getReason(), soapFault.getReason());
        assertEquals(details.hasSoapFault().getSubcode(), soapFault.getSubcode());
        // don't expect reply to address nor an identifier
        checkDetails(details, false, messageId, null);
    }
View Full Code Here

Examples of com.arjuna.wst11.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

70
71
72
73
74
75
76
77
78
79
        W3CEndpointReference coordinatorEndpoint = TestUtil.getCoordinatorEndpoint(instanceIdentifier.getInstanceIdentifier());
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(TestUtil.coordinatorServiceURI, messageId) ;

        CoordinatorClient.getClient().sendPrepared(coordinatorEndpoint, addressingProperties, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasPrepared());

        checkDetails(details, true, true, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst11.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

86
87
88
89
90
91
92
93
94
95
        W3CEndpointReference coordinatorEndpoint = TestUtil.getCoordinatorEndpoint(instanceIdentifier.getInstanceIdentifier());
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(TestUtil.coordinatorServiceURI, messageId) ;

        CoordinatorClient.getClient().sendAborted(coordinatorEndpoint, addressingProperties, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasAborted());

        checkDetails(details, false, true, messageId, instanceIdentifier);
   }
View Full Code Here

Examples of com.arjuna.wst11.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

102
103
104
105
106
107
108
109
110
111
        W3CEndpointReference coordinatorEndpoint = TestUtil.getCoordinatorEndpoint(instanceIdentifier.getInstanceIdentifier());
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(TestUtil.coordinatorServiceURI, messageId) ;

        CoordinatorClient.getClient().sendReadOnly(coordinatorEndpoint, addressingProperties, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasReadOnly());

        checkDetails(details, false, true, messageId, instanceIdentifier);
    }
View Full Code Here

Examples of com.arjuna.wst11.tests.junit.TestCoordinatorProcessor.CoordinatorDetails

118
119
120
121
122
123
124
125
126
127
        W3CEndpointReference coordinatorEndpoint = TestUtil.getCoordinatorEndpoint(instanceIdentifier.getInstanceIdentifier());
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(TestUtil.coordinatorServiceURI, messageId) ;

        CoordinatorClient.getClient().sendCommitted(coordinatorEndpoint, addressingProperties, new InstanceIdentifier("sender"));

        CoordinatorDetails details = testCoordinatorProcessor.getCoordinatorDetails(messageId, 10000);
        assertTrue(details.hasCommitted());

        checkDetails(details, false, true, messageId, instanceIdentifier);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.