All about Nitin D Gaur

JMS: Problem with Consumer Program

Yeah Ports are opened,

No error either.

Messages are enqueued in the queue, I could see it in ActiveMQ wed admin.

but I am not able to consume it.

Could this be the prefetch size problem ?
because there are multiple consumers for the queue. Currently prefetch size is 1000.
what should be the value for multiple consumers ?

ciao

Nitin

14 years ago

EJB and other Jakarta /Java EE Technologies

JMS: Problem with Consumer Program

Hi Forum,

I am using one Producer-Consumer program on Apache ActiveMQ to send and recieve messages from remote JMS-Broker server. I am able to successfully produce the message but not able to consume the response from JMS-Broker Server. Below is my program.

import java.util.Arrays;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.util.IndentPrinter;
/**
* A simple tool for publishing messages
*
* @version $Revision: 1.2 $
*/
public class RequesterTool {
private int messageCount = 10;
private long sleepTime;
private boolean verbose = true;
private int messageSize = 255;
private long timeToLive;
private String subject = "TOOL.DEFAULT";
private String replySubject;
private boolean topic;
private String user = ActiveMQConnection.DEFAULT_USER;
private String password = ActiveMQConnection.DEFAULT_PASSWORD;
private String url = ActiveMQConnection.DEFAULT_BROKER_URL;
private boolean transacted;
private boolean persistent;
private String clientId;
private long receiveTimeOut;
private Destination destination;
private Destination replyDest;
private MessageProducer producer;
private MessageConsumer consumer;
private Session session;
public static void main(String[] args) {
RequesterTool requesterTool = new RequesterTool();
args = new String[13];
args[0] = "--url=https://172.29.2.92:9443";
//args[0] = "--url=tcp://localhost:61616";
args[1] = "--topic=false";
args[2] = "--subject=MyQueueOut";
args[3] = "--persistent=false";
args[4] = "--message-count=1";
args[5] = "--message-size=3000";
args[6] = "--time-to-live=0";
args[7] = "--sleep-time=0";
args[8] = "--transacted=false";
args[9] = "--verbose=true";
args[10] = "--client-id=GL-SIM-CLIENT";
args[11] = "--reply-subject=SELECTOR_REPLIES";
args[12] = "--receive-time-out=2";
String[] unknown = CommandLineSupport.setOptions(requesterTool, args); // to set the options provided in args[]
if (unknown.length > 0) {
System.out.println("Unknown options: " + Arrays.toString(unknown));
System.exit(-1);
}
requesterTool.run();
}
public void run() {
Connection connection = null;
try {
System.setProperty("javax.net.ssl.keyStore","E:/certs/client.ks");
System.setProperty("javax.net.ssl.keyStorePassword","something");
System.setProperty("javax.net.ssl.trustStore","E:/certs/client.ts");
System.setProperty("javax.net.ssl.trustStorePassword","something");
System.out.println("Connecting to URL: " + url);
System.out.println("Publishing a Message with size " + messageSize + " to " + (topic ? "topic" : "queue") + ": " + subject);
System.out.println("Using " + (persistent ? "persistent" : "non-persistent") + " messages");
System.out.println("Sleeping between publish " + sleepTime + " ms");
// Create the connection
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("gluser", "gluser", url);
connection = connectionFactory.createConnection();
if (persistent && clientId != null && clientId.length() > 0 && !"null".equals(clientId)) {
connection.setClientID(clientId);
}
connection.start();
// Create the Session
session = connection.createSession(transacted, Session.AUTO_ACKNOWLEDGE);
// And the Destinations..
if (topic) {
destination = session.createTopic(subject);
if (replySubject == null || replySubject.equals("")) {
replyDest = session.createTemporaryTopic();
} else {
replyDest = session.createTopic(replySubject);
}
} else {
destination = session.createQueue(subject);
if (replySubject == null || replySubject.equals("")) {
replyDest = session.createTemporaryQueue();
} else {
replyDest = session.createQueue(replySubject);
}
}
System.out.println("Destination: " + destination);
System.out.println("Reply Destination: " + replyDest);
// Create the producer
producer = session.createProducer(destination);
if (persistent) {
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
} else {
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
if (timeToLive != 0) {
System.out.println("Messages time to live " + timeToLive + " ms");
producer.setTimeToLive(timeToLive);
}
// Create the reply consumer
consumer = session.createConsumer(replyDest);
// Start sending reqests.
requestLoop();
System.out.println("Done.");
// Use the ActiveMQConnection interface to dump the connection
// stats.
ActiveMQConnection c = (ActiveMQConnection)connection;
c.getConnectionStats().dump(new IndentPrinter());
} catch (Exception e) {
System.out.println("Caught: " + e);
e.printStackTrace();
} finally {
try {
connection.close();
} catch (Throwable ignore) {
}
}
}
protected void requestLoop() throws Exception {
for (int i = 0; i < messageCount || messageCount == 0; i++) {
TextMessage message = session.createTextMessage(createMessageText(i));
message.setJMSReplyTo(replyDest);
message.setJMSCorrelationID("8");
if (verbose) {
String msg = message.getText();
/* if (msg.length() > 50) {
msg = msg.substring(0, 50) + "...";
}*/
System.out.println("Sending message: " + msg);
}
producer.send(message);
if (transacted) {
session.commit();
}
System.out.println("Waiting for reponse message...");
Message message2 = consumer.receive();
//Message message2 = consumer.receiveNoWait();
System.out.println("after");
if (message2 instanceof TextMessage) {
System.out.println("Reponse message: " + ((TextMessage)message2).getText());
} else {
System.out.println("Reponse message: " + message2);
}
if (transacted) {
session.commit();
}
Thread.sleep(sleepTime);
}
}
/**
* @param i
* @return
*/
private String createMessageText(int index) {
StringBuffer buffer = new StringBuffer(messageSize);
//buffer.append("Message: " + index + " sent at: " + new Date());
buffer.append("Request Message");
if (buffer.length() > messageSize) {
return buffer.substring(0, messageSize);
}
for (int i = buffer.length(); i < messageSize; i++) {
buffer.append(' ');
}
return buffer.toString();
}
public void setClientId(String clientId) {
this.clientId = clientId;
}
public void setPersistent(boolean durable) {
this.persistent = durable;
}
public void setMessageCount(int messageCount) {
this.messageCount = messageCount;
}
public void setMessageSize(int messageSize) {
this.messageSize = messageSize;
}
public void setPassword(String password) {
this.password = password;
}
public void setSleepTime(long sleepTime) {
this.sleepTime = sleepTime;
}
public void setSubject(String subject) {
this.subject = subject;
}
public void setTimeToLive(long timeToLive) {
this.timeToLive = timeToLive;
}
public void setTopic(boolean topic) {
this.topic = topic;
}
public void setQueue(boolean queue) {
this.topic = !queue;
}
public void setTransacted(boolean transacted) {
this.transacted = transacted;
}
public void setUrl(String url) {
this.url = url;
}
public void setUser(String user) {
this.user = user;
}
public void setVerbose(boolean verbose) {
this.verbose = verbose;
}
public void setReplySubject(String replySubject) {
this.replySubject = replySubject;
}
public long getReceiveTimeOut() {
return receiveTimeOut;
}
public void setReceiveTimeOut(long receiveTimeOut) {
this.receiveTimeOut = receiveTimeOut;
}
}

I tested this code locally by using a local consumer-producer program this program works fine but for remote JMS-Broker Server it doesn't.

Please somebody help.

Thanks,
Nitin

14 years ago

EJB and other Jakarta /Java EE Technologies

JMS: Problem with Consumer Program

Hi Forum,

I am using one Producer-Consumer program on Apache ActiveMQ to send and recieve messages from remote JMS-Broker server. I am able to successfully produce the message but not able to consume the response from JMS-Broker Server. Below is my program.

import java.util.Arrays;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.util.IndentPrinter;
/**
* A simple tool for publishing messages
*
* @version $Revision: 1.2 $
*/
public class RequesterTool {
private int messageCount = 10;
private long sleepTime;
private boolean verbose = true;
private int messageSize = 255;
private long timeToLive;
private String subject = "TOOL.DEFAULT";
private String replySubject;
private boolean topic;
private String user = ActiveMQConnection.DEFAULT_USER;
private String password = ActiveMQConnection.DEFAULT_PASSWORD;
private String url = ActiveMQConnection.DEFAULT_BROKER_URL;
private boolean transacted;
private boolean persistent;
private String clientId;
private long receiveTimeOut;
private Destination destination;
private Destination replyDest;
private MessageProducer producer;
private MessageConsumer consumer;
private Session session;
public static void main(String[] args) {
RequesterTool requesterTool = new RequesterTool();
args = new String[13];
args[0] = "--url=https://172.29.2.92:9443";
//args[0] = "--url=tcp://localhost:61616";
args[1] = "--topic=false";
args[2] = "--subject=MyQueueOut";
args[3] = "--persistent=false";
args[4] = "--message-count=1";
args[5] = "--message-size=3000";
args[6] = "--time-to-live=0";
args[7] = "--sleep-time=0";
args[8] = "--transacted=false";
args[9] = "--verbose=true";
args[10] = "--client-id=GL-SIM-CLIENT";
args[11] = "--reply-subject=SELECTOR_REPLIES";
args[12] = "--receive-time-out=2";
String[] unknown = CommandLineSupport.setOptions(requesterTool, args); // to set the options provided in args[]
if (unknown.length > 0) {
System.out.println("Unknown options: " + Arrays.toString(unknown));
System.exit(-1);
}
requesterTool.run();
}
public void run() {
Connection connection = null;
try {
System.setProperty("javax.net.ssl.keyStore","E:/certs/client.ks");
System.setProperty("javax.net.ssl.keyStorePassword","something");
System.setProperty("javax.net.ssl.trustStore","E:/certs/client.ts");
System.setProperty("javax.net.ssl.trustStorePassword","something");
System.out.println("Connecting to URL: " + url);
System.out.println("Publishing a Message with size " + messageSize + " to " + (topic ? "topic" : "queue") + ": " + subject);
System.out.println("Using " + (persistent ? "persistent" : "non-persistent") + " messages");
System.out.println("Sleeping between publish " + sleepTime + " ms");
// Create the connection
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("gluser", "gluser", url);
connection = connectionFactory.createConnection();
if (persistent && clientId != null && clientId.length() > 0 && !"null".equals(clientId)) {
connection.setClientID(clientId);
}
connection.start();
// Create the Session
session = connection.createSession(transacted, Session.AUTO_ACKNOWLEDGE);
// And the Destinations..
if (topic) {
destination = session.createTopic(subject);
if (replySubject == null || replySubject.equals("")) {
replyDest = session.createTemporaryTopic();
} else {
replyDest = session.createTopic(replySubject);
}
} else {
destination = session.createQueue(subject);
if (replySubject == null || replySubject.equals("")) {
replyDest = session.createTemporaryQueue();
} else {
replyDest = session.createQueue(replySubject);
}
}
System.out.println("Destination: " + destination);
System.out.println("Reply Destination: " + replyDest);
// Create the producer
producer = session.createProducer(destination);
if (persistent) {
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
} else {
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
if (timeToLive != 0) {
System.out.println("Messages time to live " + timeToLive + " ms");
producer.setTimeToLive(timeToLive);
}
// Create the reply consumer
consumer = session.createConsumer(replyDest);
// Start sending reqests.
requestLoop();
System.out.println("Done.");
// Use the ActiveMQConnection interface to dump the connection
// stats.
ActiveMQConnection c = (ActiveMQConnection)connection;
c.getConnectionStats().dump(new IndentPrinter());
} catch (Exception e) {
System.out.println("Caught: " + e);
e.printStackTrace();
} finally {
try {
connection.close();
} catch (Throwable ignore) {
}
}
}
protected void requestLoop() throws Exception {
for (int i = 0; i < messageCount || messageCount == 0; i++) {
TextMessage message = session.createTextMessage(createMessageText(i));
message.setJMSReplyTo(replyDest);
message.setJMSCorrelationID("8");
if (verbose) {
String msg = message.getText();
/* if (msg.length() > 50) {
msg = msg.substring(0, 50) + "...";
}*/
System.out.println("Sending message: " + msg);
}
producer.send(message);
if (transacted) {
session.commit();
}
System.out.println("Waiting for reponse message...");
Message message2 = consumer.receive();
//Message message2 = consumer.receiveNoWait();
System.out.println("after");
if (message2 instanceof TextMessage) {
System.out.println("Reponse message: " + ((TextMessage)message2).getText());
} else {
System.out.println("Reponse message: " + message2);
}
if (transacted) {
session.commit();
}
Thread.sleep(sleepTime);
}
}
/**
* @param i
* @return
*/
private String createMessageText(int index) {
StringBuffer buffer = new StringBuffer(messageSize);
//buffer.append("Message: " + index + " sent at: " + new Date());
buffer.append("Request Message");
if (buffer.length() > messageSize) {
return buffer.substring(0, messageSize);
}
for (int i = buffer.length(); i < messageSize; i++) {
buffer.append(' ');
}
return buffer.toString();
}
public void setClientId(String clientId) {
this.clientId = clientId;
}
public void setPersistent(boolean durable) {
this.persistent = durable;
}
public void setMessageCount(int messageCount) {
this.messageCount = messageCount;
}
public void setMessageSize(int messageSize) {
this.messageSize = messageSize;
}
public void setPassword(String password) {
this.password = password;
}
public void setSleepTime(long sleepTime) {
this.sleepTime = sleepTime;
}
public void setSubject(String subject) {
this.subject = subject;
}
public void setTimeToLive(long timeToLive) {
this.timeToLive = timeToLive;
}
public void setTopic(boolean topic) {
this.topic = topic;
}
public void setQueue(boolean queue) {
this.topic = !queue;
}
public void setTransacted(boolean transacted) {
this.transacted = transacted;
}
public void setUrl(String url) {
this.url = url;
}
public void setUser(String user) {
this.user = user;
}
public void setVerbose(boolean verbose) {
this.verbose = verbose;
}
public void setReplySubject(String replySubject) {
this.replySubject = replySubject;
}
public long getReceiveTimeOut() {
return receiveTimeOut;
}
public void setReceiveTimeOut(long receiveTimeOut) {
this.receiveTimeOut = receiveTimeOut;
}
}

I tested this code locally by using a local consumer-producer program this program works fine but for remote JMS-Broker Server it doesn't.

Please somebody help.

Thanks,
Nitin

14 years ago

EJB and other Jakarta /Java EE Technologies

AES encryption algorithm

Hi all,

Have been trying to get AES encryption and decryption algorithm, in which I can pass the security password as encryption key.

It can be done using

but the thing in here I can not pass my pwn password as encryption key, instead it uses key generated by keygenerator.

Can any body help to give any AES encryption and decryption algorithm, in which a key can be passed.

Nitin

15 years ago

Java in General

Struts-bean-el.tld issue

a quick help is really appreciated.

Thanks,
Nitin

15 years ago

Struts

Struts-bean-el.tld issue

Hi this is my code in

JSp

Struts config entry is like this

have "m1101FundTransferOwnForm" this form in my form-beans.xml.

the problem is whenever I run the application I get this msg

but if I change the scope as request in struts-config.xml it works fine. What could be possible setting remaining for the apllication. Please help I need to use scope as session only. I am new for the struts.

15 years ago

Struts

Charset Conversion

Dont be prejudice Man !!! That I am wrong.

if I use meta tag in my JSPs as.

<meta http-equiv="Content-Type" content="text/html; charset=tis-620" />
or
<meta http-equiv="Content-Type" content="text/html; charset=windows-874" />

I can manage to get proper results with the data from DB.

But when I change it to <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />

I get junk characters. I have to use utf-8 content type only becasue tis-620 and windows-874 is not supported on all mobile devices.

15 years ago

Java in General

Charset Conversion

The String which I am getting from DB is like this "¸¹Ò¤ÒÃ¡ÃØ§à·¾" this is actually thai encoding in TIS-620 or windows-874..... I cant change DB data or conf.

what I need do is to convert this string to UTF-8, so that it could be shown on Browser.

I know that this can be done through java.nio.charset. But how I am not able to figure out.

Nitin.

15 years ago

Java in General

Charset Conversion

Hi Paul,

thanks for your reply, but how to take data form browser to DB is not my problem.

my problem is how to convert data into utf-8 to be shown on browser.

If i use character encoding as windows-874 or tis-620 than its possible, but some mobile browsers dont support tis-620 and windows-874. Thats why I want to make data from DB, compatible to utf-8.

Nitin

15 years ago

Java in General

Charset Conversion

Hi All,

I am facing one problem with thai character encoding. I have some jsp pages for a mobile web application where I show some static thai text and some text is being fetched from Database tables. I am using Content-Type as "text/html; charset=utf-8".

The problem is the static thai text is appearing properly on mobile browsers but the text, fetched from database is not proper. its apearing like this "ÃËÑÊ»ÃÐ¨ÓµÑÇ" (This is the thai encoding I guess saved in database)
What could be the solution for this ?

If I use the static thai text in jsps as TIS-620 encoding and Content-Type as "text/html; charset=TIS-620". Than static and DB thai text both is coming properly. But only for some mobile browsers. May be these browsers support TIS-620 and others dont.

I have checked about java.nio.charset package, but could not find any working example over the net to convert TIS-620 text "ÃËÑÊ»ÃÐ¨ÓµÑÇ" to UTF-8.

is it possible to convert text from one charset encoding to other ?

Please help me. If I could not make you all understand the problem properly please let me know.

Nitin

15 years ago

Java in General

Nitin D Gaur

Recent posts by Nitin D Gaur