browse functionality for jms queue

Discussion:

David Dossot

2012-06-13 17:20:33 UTC

I would:
 
- clone JmsMessageRequester into JmsMessageBrowser,
 
- replace the receive operations with browse operations,
 
- create a JmsMessageBrowserFactory inspired by JmsMessageRequesterFactory but that creates JmsMessageBrowser instances,
 
- register JmsMessageBrowserFactory on the JmsConnector by calling setRequesterFactory with Spring,
 
- then use the MuleClient to issue request() operations on this connector, which will end up performing browse on the queue instead of consume.

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-15 12:46:30 UTC

Permalink

hi david,
 
Thanks for the cue, I have cloned and created the JmsMessageBrowser and JmsMessageBrowserFactory which creates a JmsMessageBrowser, but I am unable to get hold on to the "JmsMessageBrowserFactory on the JmsConnector by calling setRequesterFactory with Spring" part , how should i do that ?
 
thanks again

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

David Dossot

2012-06-15 16:22:30 UTC

Permalink

This:
 
<code>
 
<jms:connector name="OracleAQConnector" specification="1.1" ... >
 
<spring:property name="requesterFactory">
 
<spring:bean class="your.JmsMessageBrowserFactory" />
 
</spring:property>
 
</jms:connector>
 
</code>

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-18 10:12:32 UTC

Permalink

hi,
 
I have the replaced receive operations with browse operations in the JmsMessageBrowser like this:
 
<code>
 
@Override
 
protected MuleMessage doRequest(long timeout) throws Exception {
 
Session session=null;
 
QueueBrowser browser=null;
 
boolean cleanupListenerRegistered=false;
 
try{
 
final boolean topic = connector.getTopicResolver().isTopic(endpoint);
 
JmsSupport support = connector.getJmsSupport();
 
final TransactionConfig transactionConfig = endpoint.getTransactionConfig();
 
final Transaction tx = TransactionCoordination.getInstance().getTransaction();
 
boolean transacted = transactionConfig !=null && transactionConfig.isTransacted();
 
session=connector.getSession(transacted, topic);
 
if(transacted && !tx.isXA()){
 
final Session finalSession=session;
 
getConnector().getMuleContext().registerListener(new TransactionNotificationListener<TransactionNotification>() {
 
public void onNotification(TransactionNotification txNotification){
 
final int txAction = txNotification.getAction();
 
final String txId=txNotification.getTransactionStringId();
 
if((txAction==TransactionNotification.TRANSACTION_COMMITTED
 
|| txAction==TransactionNotification.TRANSACTION_ROLLEDBACK)
 
&& txId.equals(tx.getId())){
 
connector.closeQuietly(finalSession);
 
}
 
}
 
},tx.getId());
 
cleanupListenerRegistered=true;
 
}
 
Destination dest=support.createDestination(session,endpoint);
 
//Extract jms selector
 
String selector = null;
 
JmsSelectorFilter selectorFilter = connector.getSelector(endpoint);
 
if (selectorFilter != null)
 
{
 
final String expressionTemplate = selectorFilter.getExpression();
 
if (StringUtils.isNotBlank(expressionTemplate))
 
{
 
selector = connector.getMuleContext().getExpressionManager().parse(expressionTemplate, null);
 
}
 
}
 
else if (endpoint.getProperties() != null)
 
{
 
// still allow the selector to be set as a property on the endpoint
 
// to be backward compatable
 
final String expressionTemplate = (String) endpoint.getProperty(JmsConstants.JMS_SELECTOR_PROPERTY);
 
if (StringUtils.isNotBlank(expressionTemplate))
 
{
 
selector = connector.getMuleContext().getExpressionManager().parse(expressionTemplate, null);
 
}
 
}
 
String tempDurable = (String) endpoint.getProperties().get(JmsConstants.DURABLE_PROPERTY);
 
boolean durable = connector.isDurable();
 
if (tempDurable != null)
 
{
 
durable = Boolean.valueOf(tempDurable);
 
}
 
// Get the durable subscriber name if there is one
 
String durableName = (String) endpoint.getProperties().get(JmsConstants.DURABLE_NAME_PROPERTY);
 
if (durableName == null && durable && topic)
 
{
 
durableName = "mule." + connector.getName() + "." + endpoint.getEndpointURI().getAddress();
 
if (logger.isDebugEnabled())
 
{
 
logger.debug("Jms Connector for this receiver is durable but no durable name has been specified. Defaulting to: "
 
+ durableName);
 
}
 
}
 
// create browser
 
Queue q=(Queue)support.createDestination(session, endpoint);
 
browser=session.createBrowser(q);
 
// browse message
 
@SuppressWarnings("rawtypes")
 
Enumeration e = browser.getEnumeration();
 
if (null != e) {
 
while (e.hasMoreElements()) {
 
Message message = (Message)e.nextElement();
 
return createMuleMessage(message, endpoint.getEncoding());
 
}
 
}
 
return null;
 
}finally{
 
if(!cleanupListenerRegistered){
 
connector.closeSessionIfNoTransactionActive(session);
 
}
 
}
 
}
 
</code>
 
and the JmsMessageBrowserFactory is :
 
<code>
 
public class JmsMessageBrowserFactory extends AbstractMessageBrowserFactory{
 
public MessageBrowser create(InboundEndpoint endpoint) throws MuleException{
 
return new JmsMessageBrowser(endpoint);
 
}
 
}
 
</code>
 
and the config i have :
 
<code>
 
<jms:connector name="OracleAQConnector" username="**" password="**" connectionFactory-ref="connFactory" doc:name="JMS">
 
<spring:property name="requesterFactory">
 
<spring:bean class="JmsMessageBrowserFactory" />
 
</spring:property>
 
</jms:connector>
 
</code>
 
and the error I receive is a type cast error :
 
<code>
 
WARN 2012-06-18 15:02:07,421 [main] org.mule.config.spring.parsers.assembly.DefaultBeanAssembler: Cannot assign class org.mule.transport.jms.JmsConnector to interface org.mule.api.AnnotatedObject
 
WARN 2012-06-18 15:02:07,437 [main] org.mule.config.spring.parsers.assembly.DefaultBeanAssembler: Cannot assign class java.lang.Object to interface org.mule.api.AnnotatedObject
 
INFO 2012-06-18 15:02:08,890 [main] org.mule.lifecycle.AbstractLifecycleManager: Initialising model: _muleSystemModel
 
INFO 2012-06-18 15:02:09,031 [main] org.mule.lifecycle.AbstractLifecycleManager: Disposing model: _muleSystemModel
 
ERROR 2012-06-18 15:02:09,046 [main] org.mule.tooling.server.application.ApplicationDeployer: null
 
java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.springframework.beans.TypeConverterDelegate.convertIfNecessary(TypeConverterDelegate.java:231)
 
at org.springframework.beans.BeanWrapperImpl.convertIfNecessary(BeanWrapperImpl.java:447)
 
at org.springframework.beans.BeanWrapperImpl.convertForProperty(BeanWrapperImpl.java:499)
 
at org.springframework.beans.BeanWrapperImpl.convertForProperty(BeanWrapperImpl.java:493)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.convertForProperty(AbstractAutowireCapableBeanFactory.java:1363)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1322)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1076)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:517)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
 
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:291)
 
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
 
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:288)
 
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:190)
 
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:574)
 
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:895)
 
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:425)
 
at org.mule.config.spring.SpringRegistry.doInitialise(SpringRegistry.java:89)
 
at org.mule.registry.AbstractRegistry.initialise(AbstractRegistry.java:109)
 
at org.mule.config.spring.SpringXmlConfigurationBuilder.createSpringRegistry(SpringXmlConfigurationBuilder.java:116)
 
at org.mule.config.spring.SpringXmlConfigurationBuilder.doConfigure(SpringXmlConfigurationBuilder.java:73)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:46)
 
at org.mule.config.builders.AbstractResourceConfigurationBuilder.configure(AbstractResourceConfigurationBuilder.java:78)
 
at org.mule.config.builders.AutoConfigurationBuilder.autoConfigure(AutoConfigurationBuilder.java:101)
 
at org.mule.config.builders.AutoConfigurationBuilder.doConfigure(AutoConfigurationBuilder.java:57)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:46)
 
at org.mule.config.builders.AbstractResourceConfigurationBuilder.configure(AbstractResourceConfigurationBuilder.java:78)
 
at org.mule.context.DefaultMuleContextFactory.createMuleContext(DefaultMuleContextFactory.java:80)
 
at org.mule.module.launcher.application.DefaultMuleApplication.init(DefaultMuleApplication.java:203)
 
at org.mule.module.launcher.application.ApplicationWrapper.init(ApplicationWrapper.java:64)
 
at org.mule.tooling.server.application.ApplicationDeployer.main(ApplicationDeployer.java:45)
 
Exception in thread "main" org.mule.module.launcher.DeploymentInitException: IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.mule.module.launcher.application.DefaultMuleApplication.init(DefaultMuleApplication.java:215)
 
at org.mule.module.launcher.application.ApplicationWrapper.init(ApplicationWrapper.java:64)
 
at org.mule.tooling.server.application.ApplicationDeployer.main(ApplicationDeployer.java:45)
 
Caused by: org.mule.api.config.ConfigurationException: Error creating bean with name 'OracleAQConnector': Initialization of bean failed; nested exception is org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'JmsMessageBrowserFactory' to required type 'org.mule.api.transport.MessageRequesterFactory' for property 'requesterFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found (org.mule.api.lifecycle.InitialisationException) (org.mule.api.c
onfig.ConfigurationException)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:52)
 
at org.mule.config.builders.AbstractResourceConfigurationBuilder.configure(AbstractResourceConfigurationBuilder.java:78)
 
at org.mule.context.DefaultMuleContextFactory.createMuleContext(DefaultMuleContextFactory.java:80)
 
at org.mule.module.launcher.application.DefaultMuleApplication.init(DefaultMuleApplication.java:203)
 
... 2 more
 
Caused by: org.mule.api.config.ConfigurationException: Error creating bean with name 'OracleAQConnector': Initialization of bean failed; nested exception is org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'JmsMessageBrowserFactory' to required type 'org.mule.api.transport.MessageRequesterFactory' for property 'requesterFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found (org.mule.api.lifecycle.InitialisationException)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:52)
 
at org.mule.config.builders.AbstractResourceConfigurationBuilder.configure(AbstractResourceConfigurationBuilder.java:78)
 
at org.mule.config.builders.AutoConfigurationBuilder.autoConfigure(AutoConfigurationBuilder.java:101)
 
at org.mule.config.builders.AutoConfigurationBuilder.doConfigure(AutoConfigurationBuilder.java:57)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:46)
 
... 5 more
 
Caused by: org.mule.api.lifecycle.InitialisationException: Error creating bean with name 'OracleAQConnector': Initialization of bean failed; nested exception is org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'JmsMessageBrowserFactory' to required type 'org.mule.api.transport.MessageRequesterFactory' for property 'requesterFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.mule.registry.AbstractRegistry.initialise(AbstractRegistry.java:117)
 
at org.mule.config.spring.SpringXmlConfigurationBuilder.createSpringRegistry(SpringXmlConfigurationBuilder.java:116)
 
at org.mule.config.spring.SpringXmlConfigurationBuilder.doConfigure(SpringXmlConfigurationBuilder.java:73)
 
at org.mule.config.builders.AbstractConfigurationBuilder.configure(AbstractConfigurationBuilder.java:46)
 
... 9 more
 
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'OracleAQConnector': Initialization of bean failed; nested exception is org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'JmsMessageBrowserFactory' to required type 'org.mule.api.transport.MessageRequesterFactory' for property 'requesterFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:527)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)
 
at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:291)
 
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
 
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:288)
 
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:190)
 
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:574)
 
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:895)
 
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:425)
 
at org.mule.config.spring.SpringRegistry.doInitialise(SpringRegistry.java:89)
 
at org.mule.registry.AbstractRegistry.initialise(AbstractRegistry.java:109)
 
... 12 more
 
Caused by: org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'JmsMessageBrowserFactory' to required type 'org.mule.api.transport.MessageRequesterFactory' for property 'requesterFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.springframework.beans.BeanWrapperImpl.convertIfNecessary(BeanWrapperImpl.java:462)
 
at org.springframework.beans.BeanWrapperImpl.convertForProperty(BeanWrapperImpl.java:499)
 
at org.springframework.beans.BeanWrapperImpl.convertForProperty(BeanWrapperImpl.java:493)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.convertForProperty(AbstractAutowireCapableBeanFactory.java:1363)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1322)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1076)
 
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:517)
 
... 22 more
 
Caused by: java.lang.IllegalStateException: Cannot convert value of type [JmsMessageBrowserFactory] to required type [org.mule.api.transport.MessageRequesterFactory] for property 'requesterFactory': no matching editors or conversion strategy found
 
at org.springframework.beans.TypeConverterDelegate.convertIfNecessary(TypeConverterDelegate.java:231)
 
at org.springframework.beans.BeanWrapperImpl.convertIfNecessary(BeanWrapperImpl.java:447)
 
... 28 more
 
</code>
 
ami i missing type casting somewhere ?

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

David Dossot

2012-06-18 14:42:31 UTC

Permalink

I see:
 
<code>JmsMessageBrowserFactory extends AbstractMessageBrowserFactory</code>
 
I do not know the AbstractMessageBrowserFactory type: does it extend <a href="http://www.mulesoft.org/docs/site/current3/apidocs/index.html?org/mule/transport/AbstractMessageRequesterFactory.html" rel="nofollow">http://www.mulesoft.org/docs/site/cur...</a> ?

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-19 07:37:34 UTC

Permalink

hi,
 
I have made some class level changes, now am able to compile and run the same , but again the messages are consumed, instead of being browsed.the sop's are not fired also....
 
The JmsMessageBrowser:
 
<code>
 
public class JmsMessageBrowser extends AbstractMessageRequester{
 
:
 
:
 
@Override
 
protected MuleMessage doRequest(long timeout) throws Exception {
 
Session session=null;
 
QueueBrowser browser=null;
 
boolean cleanupListenerRegistered=false;
 
System.out.println("***************************13214234324************");
 
try{
 
final boolean topic = connector.getTopicResolver().isTopic(endpoint);
 
JmsSupport support = connector.getJmsSupport();
 
final TransactionConfig transactionConfig = endpoint.getTransactionConfig();
 
final Transaction tx = TransactionCoordination.getInstance().getTransaction();
 
boolean transacted = transactionConfig !=null && transactionConfig.isTransacted();
 
session=connector.getSession(transacted, topic);
 
if(transacted && !tx.isXA()){
 
final Session finalSession=session;
 
getConnector().getMuleContext().registerListener(new TransactionNotificationListener<TransactionNotification>() {
 
public void onNotification(TransactionNotification txNotification){
 
final int txAction = txNotification.getAction();
 
final String txId=txNotification.getTransactionStringId();
 
if((txAction==TransactionNotification.TRANSACTION_COMMITTED
 
|| txAction==TransactionNotification.TRANSACTION_ROLLEDBACK)
 
&& txId.equals(tx.getId())){
 
connector.closeQuietly(finalSession);
 
}
 
}
 
},tx.getId());
 
cleanupListenerRegistered=true;
 
}
 
Destination dest=support.createDestination(session,endpoint);
 
//Extract jms selector
 
String selector = null;
 
JmsSelectorFilter selectorFilter = connector.getSelector(endpoint);
 
if (selectorFilter != null)
 
{
 
final String expressionTemplate = selectorFilter.getExpression();
 
if (StringUtils.isNotBlank(expressionTemplate))
 
{
 
selector = connector.getMuleContext().getExpressionManager().parse(expressionTemplate, null);
 
}
 
}
 
else if (endpoint.getProperties() != null)
 
{
 
// still allow the selector to be set as a property on the endpoint
 
// to be backward compatable
 
final String expressionTemplate = (String) endpoint.getProperty(JmsConstants.JMS_SELECTOR_PROPERTY);
 
if (StringUtils.isNotBlank(expressionTemplate))
 
{
 
selector = connector.getMuleContext().getExpressionManager().parse(expressionTemplate, null);
 
}
 
}
 
String tempDurable = (String) endpoint.getProperties().get(JmsConstants.DURABLE_PROPERTY);
 
boolean durable = connector.isDurable();
 
if (tempDurable != null)
 
{
 
durable = Boolean.valueOf(tempDurable);
 
}
 
// Get the durable subscriber name if there is one
 
String durableName = (String) endpoint.getProperties().get(JmsConstants.DURABLE_NAME_PROPERTY);
 
if (durableName == null && durable && topic)
 
{
 
durableName = "mule." + connector.getName() + "." + endpoint.getEndpointURI().getAddress();
 
if (logger.isDebugEnabled())
 
{
 
logger.debug("Jms Connector for this receiver is durable but no durable name has been specified. Defaulting to: "
 
+ durableName);
 
}
 
}
 
// create browser
 
Queue q=(Queue)support.createDestination(session, endpoint);
 
browser=session.createBrowser(q);
 
// browse message
 
@SuppressWarnings("rawtypes")
 
Enumeration e = browser.getEnumeration();
 
if (null != e) {
 
while (e.hasMoreElements()) {
 
Message message = (Message)e.nextElement();
 
return createMuleMessage(message, endpoint.getEncoding());
 
}
 
}
 
return null;
 
}finally{
 
if(!cleanupListenerRegistered){
 
connector.closeSessionIfNoTransactionActive(session);
 
}
 
}
 
}
 
:
 
:
 
}
 
</code>
 
The JmsMessageBrowserFactory :
 
<code>
 
public class JmsMessageBrowserFactory extends AbstractMessageBrowserFactory{
 
public JmsMessageBrowser create(InboundEndpoint endpoint) throws MuleException{
 
System.out.println("***************************13214234324 Factory************");
 
return new JmsMessageBrowser(endpoint);
 
}
 
}
 
</code>
 
The AbstractMessageBrowserFactory (as requested is as follows) although JmsMessageBrowserFactory can be straight away be inherited from the AbstractMessageRequesterFactory....
 
<code>
 
public abstract class AbstractMessageBrowserFactory extends AbstractMessageRequesterFactory{
 
public AbstractMessageBrowserFactory() {
 
// TODO Auto-generated constructor stub
 
super();
 
}
 
public boolean isCreateBrowserPerRequest()
 
{
 
return false;
 
}
 
public abstract MessageRequester create(InboundEndpoint endpoint) throws MuleException;
 
public void activate(InboundEndpoint endpoint, MessageRequester browser) throws MuleException
 
{
 
browser.activate();
 
}
 
public void destroy(InboundEndpoint endpoint, MessageRequester requester)
 
{
 
requester.dispose();
 
}
 
public void passivate(InboundEndpoint endpoint, MessageRequester requester)
 
{
 
requester.passivate();
 
}
 
public boolean validate(InboundEndpoint endpoint, MessageRequester requester)
 
{
 
return (!this.isCreateBrowserPerRequest() && requester.validate());
 
}
 
@Override
 
public String toString()
 
{
 
final StringBuffer sb = new StringBuffer(60);
 
sb.append(ClassUtils.getSimpleName(this.getClass()));
 
sb.append("{this=").append(Integer.toHexString(System.identityHashCode(this)));
 
sb.append(", createBrowserPerRequest=").append(this.isCreateBrowserPerRequest());
 
sb.append('}');
 
return sb.toString();
 
}
 
}
 
</code>
 
The config is still the same, I am using the JmsInbound endpoint and using the jmsConnector on it.

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

David Dossot

2012-06-19 08:25:32 UTC

Permalink

Message requesters (and your case browsers) are not related to inbound endpoints but, as I said in my original post, "use the MuleClient to issue request() operations on this connector, which will end up performing browse on the queue instead of consume.".

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-19 11:28:32 UTC

Permalink

I have used a main method to acheive this :
 
<code>
 
public static void main(String args[]) throws MuleException,Exception{
 
AutoConfigurationBuilder configbuilder = new AutoConfigurationBuilder("bequeue.xml");
 
DefaultMuleConfiguration muleConfig = new DefaultMuleConfiguration();
 
muleConfig.setId("MY_SERVER_ID_1");
 
MuleContextBuilder contextBuilder = new DefaultMuleContextBuilder();
 
contextBuilder.setMuleConfiguration(muleConfig);
 
MuleContext muleContext = new DefaultMuleContextFactory().createMuleContext(configbuilder, contextBuilder);
 
muleContext.start();
 
MuleClient client = new MuleClient(muleContext);
 
MuleMessage message = client.request("OracleAQConnector", 5000);
 
System.out.println(message.getPayloadAsString());
 
}
 
</code>
 
it gives me a malformed endpoint exception , i did a muleclient request on the JmsConnector,
 
<code>
 
log4j:WARN No appenders could be found for logger (org.mule.context.DefaultMuleContextBuilder).
 
log4j:WARN Please initialize the log4j system properly.
 
Exception in thread "main" java.lang.IllegalStateException: Bad endpoint configuration
 
at org.mule.endpoint.URIBuilder.getEndpoint(URIBuilder.java:221)
 
at org.mule.endpoint.AbstractEndpointBuilder.getProperties(AbstractEndpointBuilder.java:469)
 
at org.mule.endpoint.AbstractEndpointBuilder.prepareToBuildEndpoint(AbstractEndpointBuilder.java:312)
 
at org.mule.endpoint.AbstractEndpointBuilder.doBuildInboundEndpoint(AbstractEndpointBuilder.java:186)
 
at org.mule.endpoint.AbstractEndpointBuilder.buildInboundEndpoint(AbstractEndpointBuilder.java:117)
 
at org.mule.endpoint.DefaultEndpointFactory.getInboundEndpoint(DefaultEndpointFactory.java:83)
 
at org.mule.endpoint.DefaultEndpointFactory.getInboundEndpoint(DefaultEndpointFactory.java:51)
 
at org.mule.module.client.MuleClient.getInboundEndpoint(MuleClient.java:718)
 
at org.mule.module.client.MuleClient.request(MuleClient.java:650)
 
at Client.main(Client.java:30)
 
Caused by: org.mule.api.endpoint.MalformedEndpointException: The endpoint "OracleAQConnector" is malformed and cannot be parsed. If this is the name of a global endpoint, check the name is correct, that the endpoint exists, and that you are using the correct configuration (eg the "ref" attribute). Note that names on inbound and outbound endpoints cannot be used to send or receive messages; use a named global endpoint instead.
 
at org.mule.endpoint.MuleEndpointURI.preprocessUri(MuleEndpointURI.java:201)
 
at org.mule.endpoint.MuleEndpointURI.<init>(MuleEndpointURI.java:139)
 
at org.mule.endpoint.URIBuilder.getEndpoint(URIBuilder.java:216)
 
... 9 more
 
</code>
 
have a doubt , that if i do not have inbound endpoints where do i configure the queue name ?,

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

David Dossot

2012-06-19 12:49:32 UTC

Permalink

Eh eh, you clearly haven't read Mule in Action :)
 
Try:
 
<code>MuleMessage message = client.request("jms://queueName&connector=OracleAQConnector", 5000);</code>
 
replacing "queueName" with whatever you need.

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-20 08:18:32 UTC

Permalink

thanks for help .... promise to work on the mule in action before the actual assignment starts... ;-), have slightly tweaked your suggestion as it was throwing an exception (queue not found) :
 
<code>
 
MuleMessage message = client.request("jms://SUB2_NTRIG?connector=OracleAQConnector", 500);
 
</code>
 
instead of :
 
<code>
 
MuleMessage message = client.request("jms://SUB2_NTRIG&connector=OracleAQConnector", 500);
 
</code>
 
no errors , runs peacefully, can get the message payload but the message is consumed !!

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

David Dossot

2012-06-20 08:38:32 UTC

Permalink

Are JmsMessageBrowserFactory and JmsMessageBrowser used at all?

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email

riba riba

2012-06-20 10:32:32 UTC

Permalink

i guess .. they are not invoked as the sop's i had put in , as I had mentioned earlier is not fired..

---------------------------------------------------------------------
To unsubscribe from this list, please visit:

http://xircles.codehaus.org/manage_email