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 <[email protected]> Authored: Sat Jun 28 13:05:37 2014 -0400 Committer: alexoree <[email protected]> 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:[email protected]";>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: [email protected] For additional commands, e-mail: [email protected]
