[EJB 3.0] - Could not obtain connection to any of these urls: Remote-IP:
by a0001428
Hi all,
I've a problem with EJB3 on JBOSS 4.2.2. I have a ejb-jar.jar in app server(remote), but I want test client with ECLIPSE(from my computer) and I try it in a main class, but I have a error.
jndi.properties:
java.naming.factory.initial = org.jnp.interfaces.NamingContextFactory
java.naming.factory.url.pkgs = org.jboss.naming:org.jnp.interfaces
java.naming.provider.url = jnp://Remote-IP:1099
public static void main(String[] args) {
/*System.setProperty("java.security.policy","client.policy");
if(System.getSecurityManager()==null)
System.setSecurityManager(new RMISecurityManager());
System.setProperty("sun.net.client.defaultReadTimeout", "100000");*/
try {
Properties properties = new Properties();
properties.load(new FileInputStream("jndi.properties"));
Context contexto = null;
contexto = new InitialContext(properties);
GreeterFacade beanRemoto = (GreeterFacade)
contexto.lookup(BouncerFacadeBean.RemoteJNDIName);
Collection resultado = beanRemoto.listadoPedidos();
for (Iterator iterator = resultado.iterator(); iterator.hasNext();) {
String object = (String) iterator.next();
System.out.println("El resultado es:" + resultado);
}
}
catch (NamingException e)
{
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
error:
javax.naming.CommunicationException: Could not obtain connection to any of these urls: Remote-IP:1099 and discovery failed with error: javax.naming.CommunicationException: Receive timed out [Root exception is java.net.SocketTimeoutException: Receive timed out] [Root exception is javax.naming.CommunicationException: Failed to connect to server Remote-IP:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server Remote-IP:1099 [Root exception is java.net.ConnectException: Connection refused: connect]]]
at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1416)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:596)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:589)
at javax.naming.InitialContext.lookup(Unknown Source)
at demoEJB.Testing.main(Testing.java:35)
Caused by: javax.naming.CommunicationException: Failed to connect to server Remote-IP:1099 [Root exception is javax.naming.ServiceUnavailableException: Failed to connect to server Remote-IP:1099 [Root exception is java.net.ConnectException: Connection refused: connect]]
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:269)
at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1387)
... 4 more
Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server Remote-IP:1099 [Root exception is java.net.ConnectException: Connection refused: connect]
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:243)
... 5 more
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.PlainSocketImpl.doConnect(Unknown Source)
at java.net.PlainSocketImpl.connectToAddress(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.(Unknown Source)
at java.net.Socket.(Unknown Source)
at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:84)
at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:77)
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:239)
... 5 more
In my remote host: command line (cmd): netstat -an
TCP 127.0.0.1:1098 0.0.0.0:0 LISTENING
TCP 127.0.0.1:1099 0.0.0.0:0 LISTENING
Note: Locally(server remote) works fine :)
I hope we can help me!!
sorry, I speak little English :)
Thanks you!!
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250521#4250521
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250521
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
Finally, the spring config to tie it all together which has hopefully survived sanitation intact. :) You will not the class names of the above classes have been fudged to protect the innocent.
Notes:
I also do not claim this is the perfect solution. There are probably further optimisations that could be made to reduce the size/complexity.
We create our own object factory and define various properties in spring.
The default jbpm context has the services injected manually to catch code that ignores the object factory. They are all named THE SAME as they would be in the jbpm config file. This is so our custom object factory will pick them up. You could rename them and put them into the objectfactory's map also.
<?xml version="1.0" encoding="UTF-8"?>
| <beans>
| <bean id="jbpmConfiguration" class="JbpmConfigurationFactoryBeanImpl">
| <property name="transactionTemplate" ref="transactionTemplate" />
| <property name="sessionFactory" ref="jBPMSessionFactory" />
| <property name="startJobExecutor" value="true" />
| <property name="objectFactory" ref="springJbpmObjectFactory" />
| <property name="processDefinitionsResources">
| <list>
| <value>classpath:where is my xml???</value>
| </list>
| </property>
| </bean>
| <bean id="springJbpmObjectFactory" class="SpringObjectFactory">
| <property name="jbpmProperties">
| <map>
| <entry key="jbpm.hide.stale.object.exceptions">
| <bean class="java.lang.Boolean"><constructor-arg value="true" /></bean>
| </entry>
| <entry key="resource.business.calendar" value="org/jbpm/calendar/jbpm.business.calendar.properties" />
| <entry key="resource.default.modules" value="org/jbpm/graph/def/jbpm.default.modules.properties" />
| <entry key="resource.converter" value="org/jbpm/db/hibernate/jbpm.converter.properties" />
| <entry key="resource.action.types" value="org/jbpm/graph/action/action.types.xml" />
| <entry key="resource.node.types" value="org/jbpm/graph/node/node.types.xml" />
| <entry key="resource.parsers" value="org/jbpm/jpdl/par/jbpm.parsers.xml" />
| <entry key="resource.varmapping" value="org/jbpm/context/exe/jbpm.varmapping.xml" />
| <entry key="resource.mail.templates" value="jbpm.mail.templates.xml" />
| <entry key="jbpm.mail.smtp.host" value="localhost" />
| <entry key="jbpm.mail.from.address" value="jbpm@noreply" />
| <entry key="jbpm.byte.block.size">
| <bean class="java.lang.Integer"><constructor-arg value="1024" /></bean>
| </entry>
| <entry key="jbpm.mail.address.resolver">
| <bean class="org.jbpm.identity.mail.IdentityAddressResolver"></bean>
| </entry>
| <entry key="jbpm.variable.resolver">
| <bean class="org.jbpm.jpdl.el.impl.JbpmVariableResolver"></bean>
| </entry>
| <entry key="jbpm.task.instance.factory">
| <bean class="org.jbpm.taskmgmt.impl.DefaultTaskInstanceFactoryImpl"></bean>
| </entry>
| </map>
| </property>
| </bean>
| <bean id="default.jbpm.context" class="org.jbpm.JbpmContext" scope="prototype">
| <constructor-arg>
| <bean class="org.jbpm.svc.Services">
| <constructor-arg>
| <map>
| <entry key="message" value-ref="message" />
| <entry key="authentication" value-ref="authentication" />
| <entry key="scheduler" value-ref="scheduler" />
| <entry key="tx" value-ref="tx" />
| <entry key="persistence" value-ref="persistence" />
| </map>
| </constructor-arg>
| </bean>
| </constructor-arg>
| <constructor-arg ref="springJbpmObjectFactory" />
| </bean>
| <bean id="jbpmCommandService" class="org.jbpm.command.impl.CommandServiceImpl">
| <constructor-arg ref="jbpmConfiguration" />
| </bean>
| <bean id="jbpm.job.executor" class="SpringJobExecutor">
| <property name="transactionTemplate" ref="transactionTemplate" />
| <property name="jbpmConfiguration" ref="jbpmConfiguration" />
| <property name="name" value="SpringJbpmJobExecutor" />
| <property name="nbrOfThreads" value="40" />
| <property name="idleInterval" value="5000" />
| <property name="maxIdleInterval" value="1700000" />
| <property name="historyMaxSize" value="20" />
| <property name="maxLockTime" value="300000" />
| <property name="lockMonitorInterval" value="60000" />
| <property name="lockBufferTime" value="5000" />
| </bean>
| <!-- services -->
| <bean id="persistence" class="org.jbpm.persistence.db.DbPersistenceServiceFactory">
| <property name="sessionFactory" ref="jBPMSessionFactory" />
| <property name="transactionEnabled" value="false" />
| <property name="currentSessionEnabled" value="true" />
| </bean>
| <bean id="authentication" class="org.jbpm.security.authentication.DefaultAuthenticationServiceFactory" />
| <bean id="message" class="org.jbpm.msg.db.DbMessageServiceFactory" />
| <bean name="tx" class="org.jbpm.tx.TxServiceFactory" />
| <bean name="scheduler" class="org.jbpm.scheduler.db.DbSchedulerServiceFactory" />
| </beans>
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250517#4250517
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250517
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
The horribly ugly delegation node...
public class JbpmSpringDelegationNode implements DecisionHandler, ActionHandler, AssignmentHandler {
| private static final long serialVersionUID = 1L;
|
| private String beanName;
| protected static BeanFactory beanFactory;
| private Object bean;
|
| public String decide(ExecutionContext executionContext) throws Exception {
| DecisionHandler dh = getBean();
| return dh.decide(executionContext);
| }
| public void execute(ExecutionContext executionContext) throws Exception {
| ActionHandler ah = getBean();
| ah.execute(executionContext);
| }
| public void assign(Assignable assignable, ExecutionContext executionContext) throws Exception {
| AssignmentHandler ah = getBean();
| ah.assign(assignable, executionContext);
| }
| @SuppressWarnings("unchecked")
| private <T> T getBean() {
| if (bean == null) {
| bean = beanFactory.getBean(beanName);
| }
| return (T) bean;
| }
| public String getBeanName() {
| return beanName;
| }
| public void setBeanName(String beanName) {
| this.beanName = beanName;
| }
|
| }
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250516#4250516
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250516
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
Other java classes we use that are almost the same or identical as the ones in the articles. Just for completeness.
Lock monitor thread:
public class SpringLockMonitorThread extends LockMonitorThread {
| private TransactionTemplate transactionTemplate;
|
| public SpringLockMonitorThread(JbpmConfiguration jbpmConfiguration,
| int lockMonitorInterval, int maxLockTime, int lockBufferTime, TransactionTemplate transactionTemplate) {
| super(jbpmConfiguration, lockMonitorInterval, maxLockTime,lockBufferTime);
| this.transactionTemplate = transactionTemplate;
| }
| @Override
| protected void unlockOverdueJobs() {
| transactionTemplate.execute(new TransactionCallback() {
| public Object doInTransaction(TransactionStatus transactionStatus) {
| SpringLockMonitorThread.super.unlockOverdueJobs();
| return null;
| }
| });
| }
| public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
| this.transactionTemplate = transactionTemplate;
| }
| }
|
Job executor:
public class SpringJobExecutor extends JobExecutor {
| private TransactionTemplate transactionTemplate;
|
| @Override
| public synchronized void start() {
| if (!isStarted) {
| for (int i = 0; i < nbrOfThreads; i++) {
| startThread();
| }
| lockMonitorThread = new SpringLockMonitorThread(jbpmConfiguration, lockMonitorInterval, maxLockTime, lockBufferTime, transactionTemplate);
| isStarted = true;
| }
| }
| @Override
| protected Thread createThread(String threadName) {
| log.info("Creating JobExecutor thread " + threadName);
| return new GfgSpringExecutorThread(threadName, this, jbpmConfiguration, transactionTemplate, idleInterval, maxIdleInterval, maxLockTime, historyMaxSize);
| }
| public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
| this.transactionTemplate = transactionTemplate;
| }
| }
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250515#4250515
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250515
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
The next is the object factory. We use a map object to store the various nebulous properties that are required as well as getting those core, spring injected service factories in there.
The map makes specifying boolean and string properties a little cleaner and allows us to remove some ugly naming in our core spring config file that would otherwise be needed.
public class SpringObjectFactory implements ObjectFactory, ApplicationContextAware {
|
| private ApplicationContext applicationContext;
| private Map<String, Object> jbpmProperties;
|
| @Override
| public Object createObject(String objectName) {
| if (getJbpmProperties().containsKey(objectName)) {
| return getJbpmProperties().get(objectName);
| }
| else if (getApplicationContext().containsBean(objectName)) {
| return getApplicationContext().getBean(objectName);
| }
| else {
| return null;
| }
| }
| @Override
| public boolean hasObject(String objectName) {
| return
| getJbpmProperties().containsKey(objectName)||
| getApplicationContext().containsBean(objectName);
| }
| public void setJbpmProperties(Map<String, Object> jbpmProperties) {
| this.jbpmProperties = jbpmProperties;
| }
| public Map<String, Object> getJbpmProperties() {
| return jbpmProperties;
| }
| @Override
| public void setApplicationContext(ApplicationContext applicationContext) {
| this.applicationContext = applicationContext;
| }
| public ApplicationContext getApplicationContext() {
| return applicationContext;
| }
| }
|
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250514#4250514
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250514
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
The next issue is the extension of the jbpm configuration object.
In this example I would like my configuration to autodeploy my process definitions at startup and fail with warnings if something is not right. I would also like the option of safely starting the jobexecutor AFTER everything is deployed and safe for processing jobs that may have already been queued up.
Notes:
The object factory being injected is our own custom one that I will talk about next.
The line:
JbpmConfiguration.Configs.setDefaultObjectFactory(objectFactory);
Is necessary because I noticed jbpm attempting to use the default factory if it was not set. This step was the one that was preventing me from completely removing all dependency on an xml file and caused some subtle transaction bugs.
A bit random to be honest and I have not looked deeply into why it is trying to undermine my config behind my back. Nasty little troll...
JbpmSpringDelegationNode.beanFactory = applicationContext;
This is the bit of code I am most unhappy with. Basically there is no way currently (unlike in jbpm4) to hook the process def lookup to the spring beanfactory. So we have to inject it manually.
The new Spring 2.5/3.0 configuration annotations could be used here to force injection of properties, but we do not use them. Until then...yuck.
public class JbpmConfigurationFactoryBeanImpl implements ApplicationContextAware, FactoryBean, InitializingBean, ApplicationListener {
| private static org.apache.log4j.Logger log = org.apache.log4j.Logger.getLogger(JbpmConfigurationFactoryBeanImpl.class);
|
| private JbpmConfiguration jbpmConfiguration;
| private TransactionTemplate transactionTemplate;
| private ObjectFactory objectFactory;
| private boolean startJobExecutor;
| private SessionFactory sessionFactory;
|
| private Resource[] processDefinitionsResources;
|
| @Override
| public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
| JbpmSpringDelegationNode.beanFactory = applicationContext;
| }
|
| public void afterPropertiesSet() throws Exception {
| JbpmConfiguration.Configs.setDefaultObjectFactory(objectFactory);
| jbpmConfiguration = new JbpmConfiguration(objectFactory);
| JbpmContext ctx = null;
| try {
| ctx = jbpmConfiguration.createJbpmContext();
| ctx.setSessionFactory(sessionFactory);
| } finally {
| if (ctx != null) {
| ctx.close();
| }
| }
| if (getProcessDefinitionsResources() != null) {
| InputStream inputStream = null;
| for (int i = 0; i < getProcessDefinitionsResources().length; i++) {
| try {
| ctx = jbpmConfiguration.createJbpmContext();
| Resource definitionLocation = getProcessDefinitionsResources();
| inputStream = definitionLocation.getInputStream();
| final ProcessDefinition processDefinition = ProcessDefinition.parseXmlInputStream(inputStream);
| final JbpmContext finalContext = ctx;
|
| getTransactionTemplate().execute(new TransactionCallback() {
| @Override
| public Object doInTransaction(TransactionStatus status) {
| finalContext.deployProcessDefinition(processDefinition);
| return null;
| }
| });
| } finally {
| if (inputStream != null) {
| inputStream.close();
| }
| if (ctx != null) {
| ctx.close();
| }
| }
| }
| }
| StaleObjectLogConfigurer.hideStaleObjectExceptions();
| }
| public Object getObject() throws Exception {
| return jbpmConfiguration;
| }
| @Override
| public Class getObjectType() {
| return JbpmConfiguration.class;
| }
| @Override
| public boolean isSingleton() {
| return true;
| }
| @Override
| public void onApplicationEvent(ApplicationEvent applicationEvent) {
| if (applicationEvent instanceof ContextClosedEvent) {
| jbpmConfiguration.getJobExecutor().stop();
| }
| if (applicationEvent instanceof ContextStartedEvent) {
| if (startJobExecutor) {
| log.info("Starting job executor ...");
| jbpmConfiguration.startJobExecutor();
| log.info("Job executor started.");
| }
| }
| }
| public void setStartJobExecutor(boolean startJobExecutor) {
| this.startJobExecutor = startJobExecutor;
| }
| public void setObjectFactory(ObjectFactory objectFactory) {
| this.objectFactory = objectFactory;
| }
| public void setSessionFactory(SessionFactory sessionFactory) {
| this.sessionFactory = sessionFactory;
| }
| public Resource[] getProcessDefinitionsResources() {
| return processDefinitionsResources;
| }
| public void setProcessDefinitionsResources(Resource[] processDefinitionsResources) {
| this.processDefinitionsResources = processDefinitionsResources;
| }
| public TransactionTemplate getTransactionTemplate() {
| return transactionTemplate;
| }
| public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
| this.transactionTemplate = transactionTemplate;
| }
| }
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250513#4250513
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250513
16 years, 10 months
[JBoss jBPM] - Re: Solution: JBPM3 and Spring Integration
by mr_magoo
Note that because of the use of the transaction template, hibernate will assume that any staleobject exception coming out of the commit is an error. It will log and throw this exception.
Personally I think this is very bad form in a library! :) In a multi-instance environment you will have to manually silence it as these optimistic lock failures are perfectly ok. They are caught and silenced in the core jbpm executor code but of course will not occur because of the delayed commit.
e.g.
org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect): [org.jbpm.job.ExecuteNode
| Job#140392]
| at org.hibernate.persister.entity.AbstractEntityPersister.check(AbstractEntityPersister.java:1782)
| [...]
| at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321) <== CULPRIT!
| [...]
| at org.jbpm.SpringExecutorThread.acquireJobs(SpringExecutorThread.java:33)
|
Please note that the above code does not deal with this problem at all. You will end up with 2 logged errors for every optimistic lock failure in a multi instance environment. The errors should be benign otherwise.
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4250511#4250511
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4250511
16 years, 10 months
