Examples of SubscribeCreationFailedFaultType

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

245
246
247
248
249
250
251
252
253
254
255
            response.setSubscriptionReference(subscription.getEpr());
            success = true;
            return response;
        } catch (EndpointRegistrationException e) {
            LOGGER.log(Level.WARNING, "Unable to register new endpoint", e);
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to register new endpoint", fault, e);
        } finally {
            if (!success && subscription != null) {
                if (subscription.getAddress() != null) {
                    subscriptions.remove(subscription.getAddress());
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

341
342
343
344
345
346
347
348
349
350
351
        }
      }
    }
    // Check all parameters
    if (consumerReference == null) {
      SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
      throw new SubscribeCreationFailedFault("Invalid ConsumerReference: null", fault);
    }
    // TODO check we can resolve endpoint
    if (topic == null) {
      InvalidFilterFaultType fault = new InvalidFilterFaultType();
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

170
171
172
173
174
175
176
177
178
179
180
      SubscribeResponse response = new SubscribeResponse();
      response.setSubscriptionReference(createEndpointReference(subscription.getAddress()));
      success = true;
      return response;
    } catch (EndpointRegistrationException e) {
      SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
      throw new SubscribeCreationFailedFault("Unable to register endpoint", fault, e);
    } finally {
      if (!success && subscription != null) {
        subscriptions.remove(subscription);
        try {
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

72
73
74
75
76
77
78
79
80
81
82
83
84
  protected void validateSubscription(Subscribe subscribeRequest) throws InvalidFilterFault, InvalidMessageContentExpressionFault, InvalidProducerPropertiesExpressionFault, InvalidTopicExpressionFault, SubscribeCreationFailedFault, TopicExpressionDialectUnknownFault, TopicNotSupportedFault, UnacceptableInitialTerminationTimeFault {
    super.validateSubscription(subscribeRequest);
        try {
            endpoint = resolveConsumer(subscribeRequest);
        } catch (Exception e) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to resolve consumer reference endpoint", fault, e);
        }
        if (endpoint == null) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to resolve consumer reference endpoint", fault);
        }
  }
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

78
79
80
81
82
83
84
85
86
    try {
      session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer consumer = session.createConsumer(jmsTopic);
            consumer.setMessageListener(this);
    } catch (JMSException e) {
      SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
      throw new SubscribeCreationFailedFault("Error starting subscription", fault, e);
    }
  }
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

235
236
237
238
239
240
241
242
243
244
245
            response.setSubscriptionReference(subscription.getEpr());
            success = true;
            return response;
        } catch (EndpointRegistrationException e) {
            LOGGER.log(Level.WARNING, "Unable to register new endpoint", e);
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to register new endpoint", fault, e);
        } finally {
            if (!success && subscription != null) {
                subscriptions.remove(subscription);
                try {
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

245
246
247
248
249
250
251
252
253
254
255
            response.setSubscriptionReference(subscription.getEpr());
            success = true;
            return response;
        } catch (EndpointRegistrationException e) {
            LOGGER.log(Level.WARNING, "Unable to register new endpoint", e);
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to register new endpoint", fault, e);
        } finally {
            if (!success && subscription != null) {
                if (subscription.getAddress() != null) {
                    subscriptions.remove(subscription.getAddress());
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

386
387
388
389
390
391
392
393
394
395
396
                }
            }
        }
        // Check all parameters
        if (consumerReference == null) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Invalid ConsumerReference: null", fault);
        }
        // TODO check we can resolve endpoint
        if (topic == null) {
            InvalidFilterFaultType fault = new InvalidFilterFaultType();
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

98
99
100
101
102
103
104
105
106
        try {
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageConsumer consumer = session.createConsumer(jmsTopic);
            consumer.setMessageListener(this);
        } catch (JMSException e) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Error starting subscription", fault, e);
        }
    }
View Full Code Here

Examples of org.oasis_open.docs.wsn.b_2.SubscribeCreationFailedFaultType

56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
            UnsupportedPolicyRequestFault, UnrecognizedPolicyRequestFault {
        //CHECKSTYLE:ON
        super.validateSubscription(subscribeRequest);
        // TODO: implement raw notifications
        if (useRaw) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Raw notifications are not supported", fault);
        }
        try {
            consumer = WSNHelper.getInstance().getPort(subscribeRequest.getConsumerReference(),
                                                       NotificationConsumer.class);
        } catch (Exception e) {
            SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
            throw new SubscribeCreationFailedFault("Unable to resolve consumer reference endpoint", fault, e);
        }
    }
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.