I am using ActiveMq alongwith Spring in my project. I want my queue to be configured to reject the duplicate messages.I tried my level best to do so. I tried googling for the same. but could not get anything.
View RepliesI have a java file 'Arithmetic.java', in which i have 2 overridden method.Now i wanted to read this file and i need to print all the method signature lines,if i found same(overridden method)signature then i have to print "overridden method found". once i find the overridden method i have to suffix the method name as methodName_overridden1, methodName_overridden2 and so on...
package com.abcd.arithmetic;
public class AllArithmatic
{
public Integer add(int x,int y,int z)
{
return (x+y-z);
}
public Float substract(float x, float y)
[code]....
till now i am able to read the lines, able to read the method names as well. but while putting the entire method signatures into an string array and the suffixing part , i am not able to proceed. The condition i have put to find out oerridden method is nnot working.i am stucked in comparing the duplicate method
//Finds Method Name, Method Return Type
if(indexOfMethod >-1 && indexOfOpenBrace >-1){
int uniqueWordsInFile=0;
//Method signature Start
//System.out.println("method line="+line.trim());
List<String> methodList = new ArrayList<String>();
methodList.add(line.trim());
[code]....
I am trying to test out the use of durable subscribers with activeMQ. I create the subscriber
connection.setClientID(clientId);
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createTopic("my.topic");
MessageConsumer consumer = session.createDurableSubscriber(destination, subscriptionName, null, false);
I then receive the message synchronously. No message as expected.If use ActiveMQ web admin console, it shows the topic, with enqueue and dequeue of 0.
I then run the test to send messages, and then exits
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = session.createTopic("my.topic");
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
String text = "Hello World! (" + i+ ")";
message = session.createTextMessage(text);
producer.send(message);
The test exits and if I look at the ActiveMQ admin console, it now shows two messages enqueued, 0 dequeued
This seems ok
Finally i run the consumer test again. It receives the messages just fine. But again the ActiveMQ admin console shows two messages enqueued and , 0 dequeued. It always shows 0 dequeued.
I even changed the test so that instead of doing a sync receive it used an async receive with a listener...but still the same behavior. The topic dequeued value is always 0 on the Topics base of the ActiveMQ web console.
I need to reject invalid input and what is best possible way to do so with the given codes:
Class:
import java.awt.Color;
import java.io.File;
import java.io.FileNotFoundException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Scanner;
[Code] .....
I have the following unit test that gives me a null pointer exception. The debugger goes to the finally block right after the line that creates a connection factory. Here's the test:
@Test
public void receiveMessage() throws Exception {
MessageConsumer consumer = null;
ConnectionFactory connectionFactory = null;
Connection connection = null;
Session session = null;
Destination destination = null;
[code]....
I'm having some issues getting this code to reject negative numbers. What I'm doing wrong.
import java.util.Random;
import java.util.Scanner;
public class ForLoop
{
public static void main (String [] args) {
Random randomNumber = new Random();
[Code] ....
This is what I have so far..
I am designing a program in-order convert Binary to Decimal values with added features:
Rejecting binary values longer than 32 bits
Prompting the user to make multiple entries after completing the binary to decimal conversion of their first entry. I was trying to code this in Nested For Loops, but I don't know if I've really done that.
Here is what i have so far.
public class BinaryToDecimal {
public static void main(String[] args){
Scanner scan = new Scanner(System.in);
String binary;
int decimal=0b10, i, rem;
boolean isBinary = true;
[Code] ....
I have a small problem with my code that I can't figure out how to make it work the way it is supposed to. The code is supposed to be a game where a user has to guess numbers between 1-1000. The program counts how many times the user tried to guess the number and it displays a certain message if the guess number is less than 10, more than 10 or 10. I was able to write the code using loops. However, the messages will not always get printed on to the screen. The code seems to work fine except for the last part where the messages, "Either you know the secret or you got lucky", "You should be able to do better", "Aha! you know the secret!" are not always displayed like they are supposed to.
import java.util.Scanner;
public class Guess1 {
public static void main(String[] args) {
int secretNumber;
secretNumber = (int) (Math.random() * 999 + 1);
Scanner input = new Scanner(System.in);
int guess;
int replay;
int test;
test=1;
replay=1;
int count=0;
[code]....
I have the following code that comes directly from the book Core Java vol 1. The last two statements are mine but when I change the last statement's String the message being logged doesn't change. For that manner when I change the level of the last statement the file doesn't update to the correct log level. What am I doing wrong?
Java Code:
public class LogTester
{
public static void main(String[] args)
{
if (System.getProperty("java.util.logging.config.class") == null
&& System.getProperty("java.util.config.file") == null)
[code]....
Forgot to say the file also only logs the old message and level from a previous recompilation
I am new to Java/OOP in general, and am trying to implement a multi-threaded system that contains a master thread, and a set of worker threads that are heterogeneous in the work they do. Once they complete the work, the workers indicate to the master by posting the result on to its queue. Here is the problem. The results of each type of work is different, and the master has to process each differently. In C (which I'm familiar with), this can be achieved by having a message type that is a union of all the expected messages, and by using a switch statement.
I thought of doing something similar in Java, by using instance of on each incoming message (each individual message class having been subclassed from a super message class) , and doing switch on that, but it doesn't seem to be the OO way to do things. The only other way I could think of was to implement an abstract method to get the type of each message, and then use the type in a switch statement, or if-then-else. Is there some other Java idiom to do this kind of processing? Also, if this is an acceptable method, why is it superior to using the reflection to find out the message type (instead of using the abstract getType())?
The message types look similar to the code below:
abstract class Message {
abstract String getType();
} class Result1 extends Message {
ResultType1 content;
String getType() {
[Code] ....
I am having issues with a few lines of code and a java.util.UnkownFormaException. Here are the issues:
Exception in thread "main" java.util.UnknownFormatConversionException: Conversion = '1'
at java.util.Formatter.checkText(Unknown Source)
at java.util.Formatter.parse(Unknown Source)
at java.util.Formatter.format(Unknown Source)
at java.util.Formatter.format(Unknown Source)
at java.lang.String.format(Unknown Source)
at Storm.toString(Storm.java:99)
at StormChaser.DisplayStorms(StormChaser.java:149)
at StormChaser.main(StormChaser.java:55)
I have tried a lot of different things but can't seem to figure it out.
import java.io.*;
import java.util.Scanner;
public class StormChaser {
public static void main(String[] args)
[code]....
MQ Issue on the Websphere 7.0.0.25 server ..Same Message is getting redelivered again and again and below exception is coming in System out log. And secondly the messages are not getting processed completely.
[4/7/14 12:14:58:616 GMT+05:30] 0000001e LocalTranCoor E WLTC0017E: Resources rolled back due to setRollbackOnly() being called.
[4/7/14 12:16:14:738 GMT+05:30] 00000062 LocalExceptio E CNTR0020E: EJB threw an unexpected (non-declared) exception during invocation of method "onMessage" on bean "BeanId(myroj#myEJB.jar#MQMessageReceiverMDB, null)". Exception data: java.lang.reflect.InvocationTargetException
at sun.reflect.GeneratedMethodAccessor77.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:37)
at java.lang.reflect.Method.invoke(Method.java:599)
at com.ibm.ejs.jms.listener.ServerSessionDispatcher.dispatch(ServerSessionDispatcher.java:47)
at com.ibm.ejs.container.MDBWrapper.onMessage(MDBWrapper.java:98)
[code]...
I am attempting to maintain separate files for different types of "messages" (user messages, field labels/buttons, data values). In this attempt I am trying to get the description of different data values. For example, a UserStatus "A" might be displayed as Active or Activo.
<bean id="messageSource" class="org.springframework.context.support.ReloadableResourceBundleMessageSource">
<property name="defaultEncoding" value="UTF-8"/>
<property name="basenames">
<list>
<value>WEB-INF/locale/messages/messages</value>
<value>WEB-INF/locale/fields/fields</value>
<value>WEB-INF/locale/values/values</value>
</list>
</property>
</bean>
Here are the relevant entries in the values_en_us.properties file:
user.status.A = Active
user.status.I = Inactive
user.status.P = Pending
I would like to build an Enum for each type of value that I can get the localized value from. In the code below, I have hardcoded the values being passed to the get message to reduce the number of variables when trying to debug this.
import java.util.EnumMap;
import java.util.HashMap;
import java.util.Locale;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public enum UserStatusEnum {
[Code] ....
When this code runs, I get the following message:
org.springframework.context.NoSuchMessageException: No message found under code 'user.status.A' for locale 'en_us'.
On this line of code:
description = appCtx.getMessage("user.status.A", null, new Locale("en_us"));
The application is already showing my custom application error messages I have in the messages localized files, but in that case the ApplicationContext is already available. Because I can get to the contents of the messages_en_us.property files, I'm assuming me config is correct. However, the classes that get the messages content are instantiated by Spring.
The Enums are not created by Spring, so my assumption is that I am doing something wrong in how I am getting a handle on the ApplicationContext or how I am using it.
After looking at the appCtx values in debug mode, I can see that the messageSource > basenames does at least contain my configuration data.
[WEB-INF/locale/messages/messages, WEB-INF/locale/fields/fields, WEB-INF/locale/values/values]
Although I don't see the whole filenames with the file extension anywhere or the property file entries.
I have some data in the database and values can be added on demand. so when ever the value added to the database i need to promt that message to all users which are accessing my website, so how can i acheive this....
View Replies View RelatedI'm working on a project that has two separate components. The first is a back end, that will do most of the heavy lifting, the other part is a front end GUI. The GUI will include the back end into it's project as an imported JAR file.
I need to be able to keep these two decoupled, as I might be writing different front ends using the same back end. The challenge in front of me (well one of many) is how to pass messages from the back end to the GUI so I can report things that are happening.
For example, if i call method FOO, FOO might do several different things; connect to a database, divide by zero, solve world hunger. I want to be able to either tie a JTextArea , or another component (or multiple components) to this stack of information, or at the very least, have something listening for this information, and when I see that my back end reports something, my front end is quickly aware of this information, and then I can process it and inform the user of the front end.
It would also be useful to be able to send a message from front end to back end , so perhaps the back end might learn that the front end user is unhappy and would like to stop running the current query.
I have one row editable datatable.I have implemented email validation to one of the column where error message must display on blur of email field.This is working fine.I have a dialog with form to be displayed in the same page. Validation is implemented to this form also with on blur event. The dialog validation message gets displayed on blur but along with that the main form also displays the same validation message. This should not happen.
JSF page
<h:form id="lpcForm">
<div id="content">
<p:commandLink id="cmdLinkDelete" value="Delete"
style="font-size:15px;padding-left:15px;" ajax="true"
action="#{lpcBean.deleteRecords}" update=":lpcForm:lpcDataTable" />
[Code] ....
The message with id lpcErrMsg is the one that i am displaying on blur in the main page when email format is wrong.And this message gets displayed with dialog field validation also although i have never referred to this id to be rendered in the dialog.
The message with id lpcDlgMsg is the message that i am displaying inside the dialog with widgetvar dlg on blur.As of now i have implemented blur event validation for the first required field in the dialog.
I have a simple method in Java through which I send commands to a machine over TCP. The problem is:
Machine can't accept more than two connections in 20 seconds.
I need to send 15-20 commands to the machine in 3 minutes.
This is my current method which is not working as it should, 2 commands get transmited but third command hangs because of the machine.
void sendCommand(String command) throws IOException {
String ipaddress = "192.168.0.2";
Socket commandSocket = null;
BufferedWriter out = null;
BufferedReader in = null;
BufferedWriter outToDetailFile = null;
[Code] .....
Basically what i need is:
1st: I need to open the connection by calling method
public void openConnection(String ipaddress, String port){
//Code to start the connection
}
2nd: I need to be able to send commands to the connection I have already opened (i will send multiple messages in time period of 5-10 minutes):
public void sendCommand(String message){
}
3rd: Close that connection
public void closeConnection(){
}
give code snipt how can achieve to duplicate values add/allow to Set.
View Replies View RelatedHow can i check the reference that is not duplicate and date format is DDDCCYYnnnnnnn, CC must be 20 and YY must not be less than the current year, nnnnnnn is the sequetial number of the file and to complete the 7 numeric characters, zero's must be populated in front of the number. DDD must be a valid reporting entity code. there must not be a duplicate. Code I try
private boolean test-date()
{
String s_Ref = this.transactionFile.getsReference();
boolean flag = true;
if(!isValidPattern(s_Ref, "[0-9]{14}"))
[Code] ....
The reference number is like 201401030234509
If there is duplicate show error code 105
I am having some difficulty adding a new item to the HashTable when a collision occurs. We can only use the basic utilities to code this, so we are coding a HashTable by hand. We have an array of length of 10, which each index holds or will hold a Node for a Linked List.
The code hashes fine, adds the item, but the problem exists when adding items that already been hashed. The project is much bigger, but this is the engine behind the rest, and I figured I would tackle this first.
The items we are adding are objects which are states containing different information, we hash based on the ASCII sum % tableSize.
Here is the code I am testing with to add items:
HashTable ht = new HashTable(10);
State az = new State("Arizona","AZ","W",2,"Y",2);
State fl = new State("Florida", "FL", "F", 2, "X", 2);
State hi = new State("Hawaii", "HI", "H", 3, "Z", 1);
State al = new State("Alabama", "AL", "A", 5, "W", 0);
ht.insert(hi);
[Code] ....
I am making a WebCrawler, and I am trying to work out a way to stop duplicate links from getting put in however ArrayList.contains() doesnt seem to be working for me can someone look at my code and see if I am doing something wrong? I have also tried variations of it such as
!link.contains(newLink)
and
!link.contains(newLink.getLinkUrl())
with no luck. The Problem area is
for(Element lnks: link){
linkSrc = lnks.absUrl("href");
WebPage newLink = new WebPage(linkSrc);
if(!link.contains(linkSrc)){
links.add(newLink);
[Code] .....
I was trying remove duplicates element from my array without using collection API but i didn't got any output from my code.Although it is compiled successfully but on execution it didn't give any output. I guess there must be some problem in function Duplicate
Java Code:
class Union {
public static void main(String...s) {
Union M=new Union();
int x[]=new int[]{1,0,1,4,10,10,10,3,567,4,3,33};
int y[]=new int[]{5,4,5,4,5,4,2,3,3,1,0};
int []w=M.merge(x,y);
[Code] .....
Is it possible to send a duplicate soup request?Basically, I have a situation where two almost identical requests can get sent but right now the response comes back as one response. I wanted visibility to the two responses and the one gets dropped off
View Replies View RelatedI need to know how many four letter strings I can generate that begin with the letter "v". Now I had been testing many ways to do this but anm stuck. I can generate a single line up only a certain amount. I need it to continue till it reaches the max number. So since it needs to always start with V i eliminated the need for four and only a 3 letter string.
package javaapplication4;
import java.util.Random;
public class JavaApplication4 {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
Random r = new Random();
int c = r.nextInt(26)+ (byte)'a';
[code]...
Is there any way to add duplicate keywords (for all java keywords) maybe in a different language such that we can program java in a different language.
View Replies View Relatedremove duplicate elements in array using with java
View Replies View Related