Package org.jboss.soa.esb.addressing

Examples of org.jboss.soa.esb.addressing.PortReference.addExtension()

574
575
576
577
578
579
580
581
582
583
584
          addr.addExtension(JMS_SECURITY_PRINCIPAL_TAG, username);
       
        if(password != null)
          addr.addExtension(JMS_SECURITY_CREDENTIAL_TAG, password);
       
        addr.addExtension(TRANSACTED_TAG, String.valueOf(transacted));
      }
      else
        throw new IllegalArgumentException("Invalid destination type! "+destinationType);
    }
    else
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
    protected EPR createReplyTo(String esbToJBpmXml, Boolean globalProcessScope, ExecutionContext executionContext)
    {
        EPR replyTo = new LogicalEPR(ServiceInvoker.INTERNAL_SERVICE_CATEGORY, JBpmCallback.JBPM_CALL_BACK_SERVICE_NAME);
        PortReference portReference = replyTo.getAddr();
        if (globalProcessScope!=null) {
            portReference.addExtension(Constants.PROCESS_SCOPE_ATTR, globalProcessScope.toString());
        }
        final Token token = executionContext.getToken() ;
        final long tokenId = token.getId();
        portReference.addExtension(Constants.TOKEN_ID, String.valueOf(tokenId));
        String nodeId = "";
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
        if (globalProcessScope!=null) {
            portReference.addExtension(Constants.PROCESS_SCOPE_ATTR, globalProcessScope.toString());
        }
        final Token token = executionContext.getToken() ;
        final long tokenId = token.getId();
        portReference.addExtension(Constants.TOKEN_ID, String.valueOf(tokenId));
        String nodeId = "";
        if (executionContext.getNode()!=null) {
            nodeId = String.valueOf(executionContext.getNode().getId());
            portReference.addExtension(Constants.NODE_ID, nodeId);
           
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
        final long tokenId = token.getId();
        portReference.addExtension(Constants.TOKEN_ID, String.valueOf(tokenId));
        String nodeId = "";
        if (executionContext.getNode()!=null) {
            nodeId = String.valueOf(executionContext.getNode().getId());
            portReference.addExtension(Constants.NODE_ID, nodeId);
           
        }
        portReference.addExtension(Constants.PROCESS_INSTANCE_ID, String.valueOf(executionContext.getProcessInstance().getId()));
       
        String counterName = Constants.PROCESS_NODE_VERSION_COUNTER  + nodeId + '_' + tokenId;
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
        if (executionContext.getNode()!=null) {
            nodeId = String.valueOf(executionContext.getNode().getId());
            portReference.addExtension(Constants.NODE_ID, nodeId);
           
        }
        portReference.addExtension(Constants.PROCESS_INSTANCE_ID, String.valueOf(executionContext.getProcessInstance().getId()));
       
        String counterName = Constants.PROCESS_NODE_VERSION_COUNTER  + nodeId + '_' + tokenId;
        Long counter = Long.getLong(String.valueOf(executionContext.getVariable(counterName)));
        if (counter!=null) {
            counter = counter + 1;
View Full Code Here
215
216
217
218
219
220
221
222
223
224
225
            counter = 0l;
        }
        //Adding to the jBPM variableMap
        executionContext.getContextInstance().setVariableLocally(counterName, counter.toString(), token);
        //Adding same value to the message
        portReference.addExtension(counterName, counter.toString());
        return replyTo;
    }
    /**
     * Sets the faultTo EPR. This way jBPM can handle a failure in the ESB service by taking a
     * exception (faultTo) transition.
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
    protected EPR createFaultTo(String esbToJBpmXml, Boolean globalProcessScope, ExecutionContext executionContext)
    {
        EPR faultTo = createReplyTo(esbToJBpmXml, globalProcessScope, executionContext);
        if (!exceptionTransition.equals("condition")) {
            PortReference portReference = faultTo.getAddr();
            portReference.addExtension(Constants.TRANSITION_NAME, exceptionTransition);
        }
        return faultTo;
    }

   
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
            final PortReference to = origEPR.getAddr() ;
            for(NamedElement element: extensions)
            {
                final QName name = element.getName() ;
                final TextElement content = (TextElement)element.getElementContent() ;
                to.addExtension(name.getLocalPart(), name.getPrefix(), name.getNamespaceURI(), content.getText()) ;
            }
           
            call.setTo(EPRHelper.getSpecificEPR(origEPR)) ;
        }
    }
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
    if ((protocol.equals(SMTP_PROTOCOL) || (protocol.equals(POP_PROTOCOL))))
    {
      PortReference addr = new PortReference(protocol+PROTOCOL_SEPARATOR+host+PORT_SEPARATOR+port);
     
      if (username != null)
        addr.addExtension(USERNAME_TAG, username);
     
      if (password != null)
        addr.addExtension(PASSWORD_TAG, password);
     
      setAddr(addr);
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
     
      if (username != null)
        addr.addExtension(USERNAME_TAG, username);
     
      if (password != null)
        addr.addExtension(PASSWORD_TAG, password);
     
      setAddr(addr);
    }
    else
      throw new IllegalArgumentException("Invalid email protocol!");
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.