sendmessageservicestub.java

彩信网关程序,SP程序,包含移动彩信代码和电信彩信代码!供学习之用

package com.hxyh.sanny.mms.telecom.service;

/*
 *  SendMessageServiceStub java implementation
 */

public class SendMessageServiceStub extends org.apache.axis2.client.Stub {
	protected org.apache.axis2.description.AxisOperation[] _operations;

	private java.util.HashMap faultExceptionNameMap = new java.util.HashMap();

	private java.util.HashMap faultExceptionClassNameMap = new java.util.HashMap();

	private java.util.HashMap faultMessageMap = new java.util.HashMap();

	private static int counter = 0;

	private static synchronized String getUniqueSuffix() {
		if (counter > 99999) {
			counter = 0;
		}
		counter = counter + 1;
		return Long.toString(System.currentTimeMillis()) + "_" + counter;
	}

	//OOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOO
	private void populateAxisService() throws org.apache.axis2.AxisFault {
		// creating the Service with a unique name
		_service = new org.apache.axis2.description.AxisService(
				"SendMessageService" + getUniqueSuffix());
		addAnonymousOperations();
		// creating the operations
		org.apache.axis2.description.AxisOperation __operation;
		_operations = new org.apache.axis2.description.AxisOperation[2];
		__operation = new org.apache.axis2.description.OutInAxisOperation();
		__operation
				.setName(new javax.xml.namespace.QName(
						"http://www.chinatelecom.com.cn/wsdl/ctcc/multimedia_messaging/send/v2_2/interface",
						"sendMessage"));
		_service.addOperation(__operation);
		_operations[0] = __operation;
		__operation = new org.apache.axis2.description.OutInAxisOperation();
		__operation
				.setName(new javax.xml.namespace.QName(
						"http://www.chinatelecom.com.cn/wsdl/ctcc/multimedia_messaging/send/v2_2/interface",
						"getMessageDeliveryStatus"));
		_service.addOperation(__operation);
		_operations[1] = __operation;
	}
	//OOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOO
	// populates the faults
	
	private void populateFaults() {
		faultExceptionNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.PolicyException");
		faultExceptionClassNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.PolicyException");
		faultMessageMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageServiceStub$PolicyExceptionE");

		faultExceptionNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.ServiceException");
		faultExceptionClassNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.ServiceException");
		faultMessageMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageServiceStub$ServiceExceptionE");

		faultExceptionNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.PolicyException");
		faultExceptionClassNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.PolicyException");
		faultMessageMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"PolicyException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageServiceStub$PolicyExceptionE");

		faultExceptionNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.ServiceException");
		faultExceptionClassNameMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.ServiceException");
		faultMessageMap
				.put(
						new javax.xml.namespace.QName(
								"http://www.chinatelecom.com.cn/schema/ctcc/common/v2_1",
								"ServiceException"),
						"cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageServiceStub$ServiceExceptionE");

	}

	/**
	 * Constructor that takes in a configContext
	 */

	public SendMessageServiceStub(
			org.apache.axis2.context.ConfigurationContext configurationContext,
			java.lang.String targetEndpoint) throws org.apache.axis2.AxisFault {
		this(configurationContext, targetEndpoint, false);
	}

	/**
	 * Constructor that takes in a configContext and useseperate listner
	 */
	public SendMessageServiceStub(
			org.apache.axis2.context.ConfigurationContext configurationContext,
			java.lang.String targetEndpoint, boolean useSeparateListener)
			throws org.apache.axis2.AxisFault {
		// To populate AxisService
		populateAxisService();
		populateFaults();
		_serviceClient = new org.apache.axis2.client.ServiceClient(
				configurationContext, _service);
		configurationContext = _serviceClient.getServiceContext()
				.getConfigurationContext();
		_serviceClient.getOptions().setTo(
				new org.apache.axis2.addressing.EndpointReference(
						targetEndpoint));
		_serviceClient.getOptions().setUseSeparateListener(useSeparateListener);
	}

	/**
	 * Default Constructor
	 */
	public SendMessageServiceStub(
			org.apache.axis2.context.ConfigurationContext configurationContext)
			throws org.apache.axis2.AxisFault {
		this(configurationContext,
				"http://localhost:9080/SendMessageService/services/SendMessage");

	}

	/**
	 * Default Constructor
	 */
	public SendMessageServiceStub() throws org.apache.axis2.AxisFault {
		this("http://localhost:9080/SendMessageService/services/SendMessage");
	}

	/**
	 * Constructor taking the target endpoint
	 */
	public SendMessageServiceStub(java.lang.String targetEndpoint)
			throws org.apache.axis2.AxisFault {
		this(null, targetEndpoint);
	}

	/**
	 * Auto generated method signature
	 * 
	 * @see cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.SendMessageService#sendMessage
	 * @param sendMessage0
	 * 
	 * @throws
	 * cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.PolicyException :
	 * @throws
	 * cn.com.chinatelecom.www.wsdl.ctcc.multimedia_messaging.send.v2_2.service.ServiceException :
	 */

	public SendMessageServiceStub.SendMessageResponseE sendMessage(
			SendMessageServiceStub.SendMessageE sendMessage0,
			org.apache.axiom.attachments.Attachments attachments)
			throws java.rmi.RemoteException,
			com.hxyh.sanny.mms.telecom.service.PolicyException,
			com.hxyh.sanny.mms.telecom.service.ServiceException {
		org.apache.axis2.context.MessageContext _messageContext = null;
		try {
			org.apache.axis2.client.OperationClient _operationClient = _serviceClient
					.createClient(_operations[0].getName());
			_operationClient.getOptions().setAction("\"\"");
			_operationClient.getOptions().setExceptionToBeThrownOnSOAPFault(
					true);
			addPropertyToOperationClient(
					_operationClient,
					org.apache.axis2.description.WSDL2Constants.ATTR_WHTTP_QUERY_PARAMETER_SEPARATOR,
					"&");

			// create a message context
			_messageContext = new org.apache.axis2.context.MessageContext();

			// create SOAP envelope with that payload
			org.apache.axiom.soap.SOAPEnvelope env = null;

			env = toEnvelope(
					getFactory(_operationClient.getOptions()
							.getSoapVersionURI()),
					sendMessage0,
					optimizeContent(new javax.xml.namespace.QName(
							"http://www.chinatelecom.com.cn/wsdl/ctcc/multimedia_messaging/send/v2_2/interface",
							"sendMessage")));

			// adding SOAP soap_headers
			_serviceClient.addHeadersToEnvelope(env);
			// set the message context with that soap envelope
			_messageContext.setEnvelope(env);

			// add the message contxt to the operation client
			_operationClient.addMessageContext(_messageContext);

			/** ***begin - 设置SOAP附件的代码**** */
			if (attachments != null) {
				_operationClient.getOptions().setProperty(
						org.apache.axis2.Constants.Configuration.ENABLE_SWA,
						org.apache.axis2.Constants.VALUE_TRUE);
				_messageContext.setAttachmentMap(attachments);
			}
			/** ***end - 设置附件的代码**** */

			// execute the operation client
			_operationClient.execute(true);
			org.apache.axis2.context.MessageContext _returnMessageContext = _operationClient
					.getMessageContext(org.apache.axis2.wsdl.WSDLConstants.MESSAGE_LABEL_IN_VALUE);
			org.apache.axiom.soap.SOAPEnvelope _returnEnv = _returnMessageContext
					.getEnvelope();
			java.lang.Object object = fromOM(_returnEnv.getBody()
					.getFirstElement(),
					SendMessageServiceStub.SendMessageResponseE.class,
					getEnvelopeNamespaces(_returnEnv));
			return (SendMessageServiceStub.SendMessageResponseE) object;
		} catch (org.apache.axis2.AxisFault f) {
			org.apache.axiom.om.OMElement faultElt = f.getDetail();
			if (faultElt != null) {
				if (faultExceptionNameMap.containsKey(faultElt.getQName())) {
					// make the fault by reflection
					try {
						java.lang.String exceptionClassName = (java.lang.String) faultExceptionClassNameMap
								.get(faultElt.getQName());
						java.lang.Class exceptionClass = java.lang.Class
								.forName(exceptionClassName);
						java.lang.Exception ex = (java.lang.Exception) exceptionClass
								.newInstance();
						// message class
						java.lang.String messageClassName = (java.lang.String) faultMessageMap
								.get(faultElt.getQName());
						java.lang.Class messageClass = java.lang.Class
								.forName(messageClassName);
						java.lang.Object messageObject = fromOM(faultElt,
								messageClass, null);
						java.lang.reflect.Method m = exceptionClass.getMethod(
								"setFaultMessage",
								new java.lang.Class[] { messageClass });
						m.invoke(ex, new java.lang.Object[] { messageObject });
						if (ex instanceof com.hxyh.sanny.mms.telecom.service.PolicyException) {
							throw (com.hxyh.sanny.mms.telecom.service.PolicyException) ex;
						}
						if (ex instanceof com.hxyh.sanny.mms.telecom.service.ServiceException) {
							throw (com.hxyh.sanny.mms.telecom.service.ServiceException) ex;
						}
						throw new java.rmi.RemoteException(ex.getMessage(), ex);
					} catch (java.lang.ClassCastException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					} catch (java.lang.ClassNotFoundException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					} catch (java.lang.NoSuchMethodException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					} catch (java.lang.reflect.InvocationTargetException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					} catch (java.lang.IllegalAccessException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					} catch (java.lang.InstantiationException e) {
						// we cannot intantiate the class - throw the original
						// Axis fault
						throw f;
					}
				} else {
					throw f;
				}
			} else {
				throw f;
			}
		} finally {
			_messageContext.getTransportOut().getSender().cleanup(
					_messageContext);
		}
	}

	/**
	 * Auto generated method signature for Asynchronous Invocations
	 * 
	 * @see SendMessageService#startsendMessage
	 * @param sendMessage0
	 * 
	 */
	public void startsendMessage(

	SendMessageServiceStub.SendMessageE sendMessage0,

	final SendMessageServiceCallbackHandler callback)

	throws java.rmi.RemoteException {

		org.apache.axis2.client.OperationClient _operationClient = _serviceClient
				.createClient(_operations[0].getName());
		_operationClient.getOptions().setAction("\"\"");
		_operationClient.getOptions().setExceptionToBeThrownOnSOAPFault(true);

		addPropertyToOperationClient(
				_operationClient,
				org.apache.axis2.description.WSDL2Constants.ATTR_WHTTP_QUERY_PARAMETER_SEPARATOR,
				"&");

		// create SOAP envelope with that payload
		org.apache.axiom.soap.SOAPEnvelope env = null;
		final org.apache.axis2.context.MessageContext _messageContext = new org.apache.axis2.context.MessageContext();

		// Style is Doc.

		env = toEnvelope(
				getFactory(_operationClient.getOptions().getSoapVersionURI()),
				sendMessage0,
				optimizeContent(new javax.xml.namespace.QName(
						"http://www.chinatelecom.com.cn/wsdl/ctcc/multimedia_messaging/send/v2_2/interface",
						"sendMessage")));

		// adding SOAP soap_headers
		_serviceClient.addHeadersToEnvelope(env);
		// create message context with that soap envelope
		_messageContext.setEnvelope(env);

		// add the message context to the operation client
		_operationClient.addMessageContext(_messageContext);

		_operationClient
				.setCallback(new org.apache.axis2.client.async.AxisCallback() {
					public void onMessage(
							org.apache.axis2.context.MessageContext resultContext) {
						try {
							org.apache.axiom.soap.SOAPEnvelope resultEnv = resultContext
									.getEnvelope();

							java.lang.Object object = fromOM(
									resultEnv.getBody().getFirstElement(),
									SendMessageServiceStub.SendMessageResponseE.class,
									getEnvelopeNamespaces(resultEnv));
							callback
									.receiveResultsendMessage((SendMessageServiceStub.SendMessageResponseE) object);

						} catch (org.apache.axis2.AxisFault e) {
							callback.receiveErrorsendMessage(e);
						}
					}

					public void onError(java.lang.Exception error) {
						if (error instanceof org.apache.axis2.AxisFault) {
							org.apache.axis2.AxisFault f = (org.apache.axis2.AxisFault) error;
							org.apache.axiom.om.OMElement faultElt = f
									.getDetail();
							if (faultElt != null) {
								if (faultExceptionNameMap.containsKey(faultElt
										.getQName())) {
									// make the fault by reflection
									try {
										java.lang.String exceptionClassName = (java.lang.String) faultExceptionClassNameMap
												.get(faultElt.getQName());
										java.lang.Class exceptionClass = java.lang.Class
												.forName(exceptionClassName);
										java.lang.Exception ex = (java.lang.Exception) exceptionClass
												.newInstance();
										// message class
										java.lang.String messageClassName = (java.lang.String) faultMessageMap
												.get(faultElt.getQName());
										java.lang.Class messageClass = java.lang.Class
												.forName(messageClassName);
										java.lang.Object messageObject = fromOM(
												faultElt, messageClass, null);
										java.lang.reflect.Method m = exceptionClass
												.getMethod(
														"setFaultMessage",
														new java.lang.Class[] { messageClass });
										m
												.invoke(
														ex,
														new java.lang.Object[] { messageObject });

										if (ex instanceof com.hxyh.sanny.mms.telecom.service.PolicyException) {
											callback
													.receiveErrorsendMessage((com.hxyh.sanny.mms.telecom.service.PolicyException) ex);
											return;
										}