133134135136137138139140141142143
e.printStackTrace(); System.out.println("unable to unsubscribe, ignoring"); } // shutdown the consumer service. client.shutdownConsumerService(); System.out.println("interrupted"); }
130131132133134135136137138139140
134135136137138139140141142143144
126127128129130131132133134135136
e.printStackTrace(); fail("invalid xml recieved: " + e.getMessage()); } wseMsgBrokerClient.unSubscribe(subscriptionID); wseMsgBrokerClient.shutdownConsumerService(); } catch (AxisFault e) { e.printStackTrace(); fail("unexpected exception occured"); }
123124125126127128129130131132133
e.printStackTrace(); fail("invalid xml recieved: " + e.getMessage()); } msgBrokerClient.unSubscribe(subscriptionID); msgBrokerClient.shutdownConsumerService(); } catch (AxisFault e) { e.printStackTrace(); fail("unexpected exception occured"); }
137138139140141142143144145146147
8889909192939495969798
wseMsgBrokerClient.unSubscribe(subscriptionID); } catch (AxisFault e) { e.printStackTrace(); fail(e.getMessage()); } wseMsgBrokerClient.shutdownConsumerService(); } catch (AxisFault e) { e.printStackTrace(); try { System.in.read();
} catch (AxisFault e) { e.printStackTrace(); fail(e.getMessage()); } wsntMsgBrokerClient.shutdownConsumerService(); } catch (AxisFault e) { e.printStackTrace(); try { System.in.read();