You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@juddi.apache.org by al...@apache.org on 2014/06/28 19:06:00 UTC
git commit: missed a file on the last commit
Repository: juddi
Updated Branches:
refs/heads/master c807b057d -> 977f51397
missed a file on the last commit
Project: http://git-wip-us.apache.org/repos/asf/juddi/repo
Commit: http://git-wip-us.apache.org/repos/asf/juddi/commit/977f5139
Tree: http://git-wip-us.apache.org/repos/asf/juddi/tree/977f5139
Diff: http://git-wip-us.apache.org/repos/asf/juddi/diff/977f5139
Branch: refs/heads/master
Commit: 977f51397086e0e9e213ca6edb6248e1990ab514
Parents: c807b05
Author: alexoree <al...@apache.org>
Authored: Sat Jun 28 13:05:37 2014 -0400
Committer: alexoree <al...@apache.org>
Committed: Sat Jun 28 13:05:37 2014 -0400
----------------------------------------------------------------------
.../samples/UddiSubscribeAssertionStatus.java | 148 +++++++++++++++++++
1 file changed, 148 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/juddi/blob/977f5139/juddi-examples/more-uddi-samples/src/main/java/org/apache/juddi/samples/UddiSubscribeAssertionStatus.java
----------------------------------------------------------------------
diff --git a/juddi-examples/more-uddi-samples/src/main/java/org/apache/juddi/samples/UddiSubscribeAssertionStatus.java b/juddi-examples/more-uddi-samples/src/main/java/org/apache/juddi/samples/UddiSubscribeAssertionStatus.java
new file mode 100644
index 0000000..19839d9
--- /dev/null
+++ b/juddi-examples/more-uddi-samples/src/main/java/org/apache/juddi/samples/UddiSubscribeAssertionStatus.java
@@ -0,0 +1,148 @@
+/*
+ * Copyright 2001-2013 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.juddi.samples;
+
+import javax.xml.datatype.DatatypeFactory;
+import org.apache.juddi.jaxb.PrintUDDI;
+import org.apache.juddi.v3.client.UDDIConstants;
+import org.apache.juddi.v3.client.config.UDDIClerk;
+import org.apache.juddi.v3.client.config.UDDIClient;
+import org.apache.juddi.v3.client.subscription.ISubscriptionCallback;
+import org.apache.juddi.v3.client.subscription.SubscriptionCallbackListener;
+import org.apache.juddi.v3.client.transport.Transport;
+import org.apache.juddi.v3_service.JUDDIApiPortType;
+import org.uddi.api_v3.*;
+import org.uddi.sub_v3.Subscription;
+import org.uddi.sub_v3.SubscriptionFilter;
+import org.uddi.sub_v3.SubscriptionResultsList;
+import org.uddi.v3_service.UDDIInquiryPortType;
+import org.uddi.v3_service.UDDIPublicationPortType;
+import org.uddi.v3_service.UDDISecurityPortType;
+import org.uddi.v3_service.UDDISubscriptionPortType;
+
+/**
+ * Thie class shows you how to create a business and a subscription using UDDI
+ * Subscription asynchronous callbacks for Assertion Status Reports
+ *
+ * @author <a href="mailto:alexoree@apache.org">Alex O'Ree</a>
+ */
+public class UddiSubscribeAssertionStatus implements ISubscriptionCallback, Runnable {
+
+ private static UDDISecurityPortType security = null;
+ private static JUDDIApiPortType juddiApi = null;
+ private static UDDIPublicationPortType publish = null;
+ private static UDDIInquiryPortType uddiInquiryService = null;
+ private static UDDISubscriptionPortType uddiSubscriptionService = null;
+ boolean callbackRecieved = false;
+ private UDDIClerk clerk = null;
+ private UDDIClient client = null;
+
+ public UddiSubscribeAssertionStatus() {
+ try {
+ // create a manager and read the config in the archive;
+ // you can use your config file name
+ client = new UDDIClient("META-INF/simple-publish-uddi.xml");
+ clerk = client.getClerk("default");
+ Transport transport = client.getTransport();
+ // Now you create a reference to the UDDI API
+ security = transport.getUDDISecurityService();
+ juddiApi = transport.getJUDDIApiService();
+ publish = transport.getUDDIPublishService();
+ uddiInquiryService = transport.getUDDIInquiryService();
+ uddiSubscriptionService = transport.getUDDISubscriptionService();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void main(String args[]) throws Exception {
+ UddiSubscribeAssertionStatus sp = new UddiSubscribeAssertionStatus();
+ sp.Fire();
+ }
+
+ public void Fire() throws Exception {
+
+ TModel createKeyGenator = UDDIClerk.createKeyGenator("somebusiness", "A test key domain SubscriptionCallbackTest1", "SubscriptionCallbackTest1");
+
+ clerk.register(createKeyGenator);
+ System.out.println("Registered tModel keygen: " + createKeyGenator.getTModelKey());
+
+ //setup the business to attach to
+ BusinessEntity be = new BusinessEntity();
+ be.setBusinessKey("uddi:somebusiness:somebusinesskey");
+ be.getName().add(new Name("somebusiness SubscriptionCallbackTest1", null));
+ be.setBusinessServices(new BusinessServices());
+ BusinessService bs = new BusinessService();
+ bs.setBusinessKey("uddi:somebusiness:somebusinesskey");
+ bs.setServiceKey("uddi:somebusiness:someservicekey");
+ bs.getName().add(new Name("service SubscriptionCallbackTest1", null));
+ be.getBusinessServices().getBusinessService().add(bs);
+ BusinessEntity register = clerk.register(be);
+ System.out.println("Registered business keygen: " + register.getBusinessKey());
+
+ //start up our listener
+ BindingTemplate start = SubscriptionCallbackListener.start(client, "default");
+
+ //register for callbacks
+ SubscriptionCallbackListener.registerCallback(this);
+
+ Subscription sub = new Subscription();
+ sub.setNotificationInterval(DatatypeFactory.newInstance().newDuration(1000));
+ sub.setBindingKey(start.getBindingKey());
+ sub.setSubscriptionFilter(new SubscriptionFilter());
+ sub.getSubscriptionFilter().setGetAssertionStatusReport(new GetAssertionStatusReport());
+
+
+ Subscription subscriptionBiz = clerk.register(sub, clerk.getUDDINode().getApiNode());
+
+ System.out.println("Registered GetAssertionStatus subscription key: " + (subscriptionBiz.getSubscriptionKey()) + " bindingkey: " + subscriptionBiz.getBindingKey());
+
+ System.out.println("Waiting for callbacks. Now would be a good time to launch either another program or juddi-gui to make some changes. Press any key to stop!");
+ //Thread hook = new Thread(this);
+ // Runtime.getRuntime().addShutdownHook(hook);
+
+ System.in.read();
+
+ SubscriptionCallbackListener.stop(client, "default", start.getBindingKey());
+ clerk.unRegisterSubscription(subscriptionBiz.getSubscriptionKey());
+
+ clerk.unRegisterTModel(createKeyGenator.getTModelKey());
+
+ clerk.unRegisterBusiness("uddi:somebusiness:somebusinesskey");
+
+ //Runtime.getRuntime().removeShutdownHook(hook);
+ }
+
+ private boolean running = true;
+ PrintUDDI<SubscriptionResultsList> p = new PrintUDDI<SubscriptionResultsList>();
+
+ @Override
+ public void HandleCallback(SubscriptionResultsList body) {
+ System.out.println("Callback received!");
+ System.out.println(p.print(body));
+ }
+
+ @Override
+ public void NotifyEndpointStopped() {
+ System.out.println("The endpoint was stopped!");
+ }
+
+ @Override
+ public void run() {
+ running = false;
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@juddi.apache.org
For additional commands, e-mail: commits-help@juddi.apache.org