Consumption consume slowly - high UNACK message

I have glassfish 2.1 with OpenMQ 4.3.

I have other posts related to the similar project. But I see all these different symptoms, so I put it in different threads.

I'm running on this issue, where consumers consume messages very slowly (200 RPM). It starts fine (3000 rpm), but in 20-25 hours it suddenly slows to slow. If anyone has any suggestions on how to diagnose the exact problem, I'd appreciate that. I'm also try using version 4.5 of OpenMQ by simply replacing the bin/lib files. But a solution with OpenMQ 4.3 is certainly preferred...

I also see a high number of messages of high Unack

-----------------------------------------------------------------------------------------------------
Name Type State producers consumers Msgs
Total of generic wildcard County remote UnAck Avg size
-----------------------------------------------------------------------------------------------------
BillingQueue queue running 0-0 - 0 0 0 0.0
testStatsQueue queue 0-0 running - 72 0 77 1441.6111
EsafQueue queue running 0-0 - 0 0 0 0.0
Section 0 0 5 0 440 80 20 1328.0 running InitialDestination
Queue queue running 0-0 - 0 0 0 0.0
MQ.sys.DMQ queue running 0-0 - 0 0 0 0.0

Here is the excerpt of the consumer code:

I create the connection in @postConstruct and close in @preDestroy, so that I don't have to do it every time.

private ResultMessage [] doRetrieve (String username, String password, String jndiDestination, String filter, int maxMessages, long timeout, type RetrieveType)
throws InvalidCredentialsException, InvalidFilterException, ConsumerException {}

// ******************************************************************
Resources
// ******************************************************************

A session = null;

try {}

If (log.isTraceEnabled ()) log.trace ("session creation treated with JMS broker.");
session = connection.createSession (Session.SESSION_TRANSACTED, true);

// **************************************************************
Locate the linked destination and create a consumer
// **************************************************************

If (log.isTraceEnabled ()) log.trace ("looking for a named destination:" + jndiDestination);
Destination destination = ic.lookup (jndiDestination) (Destination);

If (log.isTraceEnabled ()) log.trace ("Creation of consumer to destination named" + jndiDestination);
MessageConsumer = consumption (filter == null | filter.trim () .length () == 0)? session.createConsumer (destination): session.createConsumer (destination, filter);

If (log.isTraceEnabled ()) log.trace ("JMS connection starting.");
Connection.Start ();

// **************************************************************
Consume messages
// **************************************************************

If (log.isDebugEnabled ()) log.trace ("Creating recovery containers.");
The < ResultMessage > list processedMessages = new ArrayList < ResultMessage > (maxMessages);
BytesMessage jmsMessage = null;

for (int i = 0; i < maxMessages; i ++) {}

// **********************************************************
Retrieve message attempt
// **********************************************************

If (log.isTraceEnabled ()) log.trace ("recovery attempt:" + i);
switch (type) {}
BLOCKING of the case:
jmsMessage = consumer.receive () (BytesMessage);
break;
IMMEDIATE case:
jmsMessage = consumer.receiveNoWait () (BytesMessage);
break;
TIMED case:
jmsMessage = consumer.receive (timeout) (BytesMessage);
break;
}

// **********************************************************
Process of recovered messages
// **********************************************************

If (jmsMessage! = null) {}

If (log.isTraceEnabled ()) log.trace ("Message retrieved\n" + jmsMessage);

// ******************************************************
Extract the message
// ******************************************************

If (log.isTraceEnabled ()) log.trace ("" extraction result message the JMS message containing "");
Byte [] extracted = new byte [(int) jmsMessage.getBodyLength ()];
jmsMessage.readBytes (extracted);

// ******************************************************
Message to decompress
// ******************************************************

If (jmsMessage.propertyExists (COMPRESSED_HEADER) & & jmsMessage.getBooleanProperty (COMPRESSED_HEADER)) {}
If (log.isTraceEnabled ()) log.trace ("Decompressing message.");
excerpt = since (extracted);
}

// ******************************************************
Message from treatment
// ******************************************************

If (log.isTraceEnabled ()) log.trace ("Message added to the recovery container.");

String signature = jmsMessage.getStringProperty (DIGITAL_SIGNATURE);
processedMessages.add (new ResultMessage (excerpt, signature));

} else
If (log.isTraceEnabled ()) log.trace ("no message was available.");

}

// **************************************************************
Container package return
// **************************************************************

If (log.isTraceEnabled ()) log.trace ("packaging recovered to return messages.");
ResultMessage [] collectorMessages = new ResultMessage [processedMessages.size ()];
for (int i = 0; i < collectorMessages.length; i ++)
collectorMessages = processedMessages.get (i);

If (log.isTraceEnabled ()) log.trace ("Return" + collectorMessages.length + "messages.");
Return collectorMessages;

} catch (NamingException ex) {}
sessionContext.setRollbackOnly ();
log. Error ("unable to locate the named queue:" + jndiDestination, ex);
throw new ConsumerException ("unable to locate the named queue:" + jndiDestination, ex);
} catch (InvalidSelectorException ex) {}
sessionContext.setRollbackOnly ();
log. Error ("invalid filter:" + filter, ex);
throw new InvalidFilterException ("invalid filter:" + filter, ex);
} catch (IOException ex) {}
sessionContext.setRollbackOnly ();
log. Error ("Message of decompression failed.", ex);
throw new ConsumerException ("Message of decompression failed.", ex);
} catch (GeneralSecurityException ex) {}
sessionContext.setRollbackOnly ();
log. Error ("Decryption doesn't have a Message.", ex);
throw new ConsumerException ("Decryption doesn't have a Message.", ex);
} catch (JMSException ex) {}
sessionContext.setRollbackOnly ();
log. Error ("Cannot consumer messages.", ex);
throw new ConsumerException ("Impossible to consume messages.", ex);
} catch (Throwable ex) {}
sessionContext.setRollbackOnly ();
log. Error ("Unexpected error.", ex);
throw new ConsumerException ("Unexpected error.", ex);
} {Finally
try {}
If (session! = null) session.close ();
} catch (JMSException ex) {}
log. Error ("Unexpected error.", ex);
}
}

}

Published by: vineet may 9, 2011 19:53

The questions you have posted related to the delivery of messages from consumers in the above test case might be all related to bugs 6961586 and 6972137 which have been fixed in 4.4u2p2 and 4.5. The symptoms caused by these 2 bugs are not limited to those in bug descriptions, for example the cause of the bug 6972137 directly affect the 'busy' State consumer notification. Please update or try to 4.5. As your application runs in the GlassFish server, please follow the notes in the following thread to try 4.5 with GlassFish 2.x
How to check the number of update for OpenMQ

Tags: Oracle

Similar Questions

Just installed a new HP209-a. When idle, spoolsv.exe consumed slowly all of the memory to the point where I have to reboot.

XP with new HP209 - installed printer system. Look at a process through the Task Manager, I can watch spoolsv.exe slowly consume all the memory. This happens without any printing activity. Tried to uninstall and then reinstall the printer, but has not fixed the problem. All of the suggestions.

Yes, but you will lose the benefit of the queue.

In fact found that change the HP TCP/IP to Standard TCP/IP printer port seems to have solved the problem.

Explorer Windows consumes a high percentage of CPU recently in Windows 8

Recently, I think that after the last update of Windows 8, a process called "Windows Explorer (32-bit)" consumes about 70% of the CPU, almost all the time.

He's not slowing down my computer much, but still, when I open "Task Manager", he is always on the top about the CPU usage. However, once when I tried to shut down my computer, it says something like--an application prevents the closure - my cell phone then returns to the Office and I had to wait until this process & a few others as the 'system', ' Service Host: Local Service', etc., only a few similar, completed processes. There is no charge on my laptop, I mean around 8-10% usage of these categories listed in the Manager of tasks, then I was able to stop.

Any idea on this?

Hello

I suggest for the update of the BIOS and you are trying to update to Windows 8.1.

I suggest you scan your computer with the Microsoft Security Scanner, which would help us to get rid of viruses, spyware and other malicious software. The Microsoft Security Scanner is a downloadable security tool for free which allows analysis at the application and helps remove viruses, spyware and other malware. It works with your current antivirus software.

http://www.Microsoft.com/security/scanner/en-us/default.aspx

Also refer to this link: http://windows.microsoft.com/en-us/windows-8/how-find-remove-virus

Note: The Microsoft Safety Scanner ends 10 days after being downloaded. To restart a scan with the latest definitions of anti-malware, download and run the Microsoft Safety Scanner again.

Warning: The data files that are infected must be cleaned only by removing the file completely, which means that there is a risk of data loss.

Hope this helps

Valerie high CPU

Hello

What is the process/usr/libexec/logd? It consumes a high percentage of CPU:

After 4 hours of high processor, I restarted my laptop and now the process uses more high percentage of cpu. I guess it's a bug in MacOs Sierra

Using 6509 DIO as input to trigger the TCP messaging

I'm a traditional GPIB instrument and no TCP, and I asked a question.

Is it possible to use the 6509 and a benchtop time signal generator a loop of LabVIEW? We have a loop that runs not controlled at a high rate (messages TCP). We would like to input pulse or square wave signal in the 6509 and trigger messages 1 to 3 kHz TCP (less than the loop runs not controlled). It comes to the fine TCP performance benchmarking; We use a loop timed at rates up to 1 kHz with good results, we need higher than the rate of 1 kHz.

Is this possible?

Hi Philippe,.

This has been reported to R & D (461F39IG ID CAR) and has been fixed in LabVIEW 8.20. Here is a link to the download the current for LabVIEW evaluation software. Thank you!

Kind regards
Andrew W
National Instruments

status of landmark HP + generic host process for the + serious mistake WMI + system configuration utility + ALG pop-up messages

I have a desktop computer, with Windows XP. He has a very good performance for 4 years. But in recent days, some of the messages appeared, and suddenly, the computer restarts. and if she did ' t restart directly, she performed very bad (gel + slowly). 6 messages appeared, they are:

1 - generic host process for win32 services has encountered a problem

2 - problem WMI

3 - the system has recovered from a serious error

4 system configuration utility

Situation 5 - hp cue has encountered a problem

6-application Layer Gateway service

Help, please.

Hi Alaa' Kabbani,.

1. did you of recent changes made to your computer?

2. which antivirus app do you use?

3. What is the brand and model of your computer?

I suggest to follow the steps below and we update on the State of the question.

Method 1: Disconnect any new hardware

If you have recently installed a new hardware device, the necessary driver so that the material can not be installed or the driver may be damaged or incompatible. To determine if this is true, follow these steps:

1 unplug the appliance.

2. restart Windows XP.

If Windows XP starts successfully, there is a driver problem with the new material. Contact the manufacturer of the device for drivers updated to the device or to learn more about known hardware issues, so that you can reinstall the device.

For information about how to contact the manufacturer of the device, refer to the Microsoft Web site at the following address:

http://support.Microsoft.com/GP/vendors

(http://support.microsoft.com/gp/vendors)

Microsoft provides third-party contact information to help you find technical support. These details may change without notice. Microsoft does not guarantee the accuracy of this third-party contact information.

If this method resolved the issue, you are finished. If this method does not work for you, go to method 3.

Method 2: Disable automatic reboot in case of system failure

If the system reboots continuously, do the following:

1. reboot the computer.

2. as the computer restarts, press the F8 key repeatedly until you see the Windows Advanced Options screen.

3. use the arrow keys to select disable automatic system error rebootand press ENTER.

4. If you receive an error message, follow these steps to search the Microsoft Knowledge Base for useful information about the error message:

a. copy the text of the error message.

b. visit the following Microsoft Web site:

http://support.Microsoft.com

(http://support.microsoft.com)

c. type the text of the error message in the Search box, and then type the name of the product you are using, for example "Windows XP".

d. click on Searchand try to find an article that will help you solve your problem.

If this method worked, you have resolved the problem of your computer restarts continuously. However, you can continue to troubleshoot driver problems. See the "Symptoms" section again and determine which method to use to solve the problem.

If this method worked, you are finished. If this method does not work for you, please try Method 3.

Method 3: Use the known last good Configuration feature

If you can start the computer successfully, you can use the known last good Configuration feature. This feature uses information that was saved the last time that you shut down the computer before the problems started. This feature allows to restore your registry settings and drivers to the previous information.

If you are not completely sure what that means, don't worry. None of these reviews will damage your computer. However, you should be aware that if you do this, any changes made to your computer after the date of last known good configuration will be lost.

If you have recently installed a driver and know a configuration problem, this method will probably work for you. Unfortunately, this feature does not solve the problems caused by missing drivers or corrupt or files.

To use the last good known Configuration, follow these steps:

a. restart the computer.

(b) that the computer restarts, press the F8 key repeatedly until you see the Windows Advanced Options screen.

c. use the arrow keys to select last good Configuration known (your most recent settings that worked), and then press ENTER.

d. If you are prompted to select an operating system, use the arrow keys to select the operating system and press ENTER.

If this method worked, your computer is restored to a good working state. You still have to investigate on what caused this problem. To do this, please see the "Next steps" section for troubleshooting resources more.

Also refer to this link: Slow PC? Optimize your computer for peak performance

http://www.Microsoft.com/athome/Setup/optimize.aspx#fBid=G1iW6Kb0x5J

WARNING CHKDSK:

Running chkdsk on the drive if bad sectors are found on the disk hard when chkdsk attempts to repair this area if all available on which data can be lost.

Anti Virus WARNING: The data files that are infected must be cleaned only by removing the file completely, which means that there is a risk of data loss.

If you have trouble following the suggested steps or if the problem persists, please let us know and we are ready to answer them for you.

Windows Update Service consume 100% of load on a kernel (Windwos 7)

Hello

This Monday week Windows update service (wuauserv) is constantly consuming 100% of load with one heart. The system is completely updated, all the updates are applied. I know that Windows update is generally the software kind of crap (sorry guys, but there are a lot of things to improve) and usually consumes CPU high for a long time just check the updates (installation also last very long), but this time he keeps everything simply.

Restaring the service did not help. Restart does not help either. I tried to re - install all the com - dll, restarted the service,... nothing helps. Then I tried to apply the tool but this Fixit tool seems to be "smart" enough and starts the wuauserv service in order to detect problems--> same charge again.

My system is Windows 7-64 and is usually very fast (Core - I 7, 2.6 GHz, 8 GB of Ram, 512 GB SSD) is NOT the PC.

Thank you

KE

Some additional background information, since this topic got referenced from another site: in the case where the installer of KB3161608 returns "the update is not applicable to your computer", the sine qua non, KB3020369, is absent.

"To apply this update, you must install [...] April 2015 maintenance battery update for Windows 7 and Windows Server 2008 R2 (KB3020369). »

Best regards, VZ

How to display an automatic alert message?

I'm listening to incoming e-mail messages and must display an alert if an incoming message arrives with a HIGH priority.

I can listen and view a message using System.out.println. But I can't able to show a Dialog.alert ("new E-mail message");

It shows the following error message:

"" Eception exception: pushModalScreen called by a thread of non-event ".

I tried to call through invokeLater, but both EventQueue and SwingUtilities are not available with BlackBerry JDE 4.7.0.41

How can I display an alert automatically, when a new HIGH-priority message arrives? Is all classes available for this purpose?

Here is an article from the second suggestion of Simon documents.

How - to alert a user to a background application
Article number: DB-00407
http://www.BlackBerry.com/knowledgecenterpublic/livelink.exe/fetch/2000/348583/800332/800505/800608/...

Edit: Just found this, which I think that documents first suggestion of Simon:

How to allow - a listener in the background to detect and update a GUI application
Article number: DB-00406
http://www.BlackBerry.com/knowledgecenterpublic/livelink.exe/fetch/2000/348583/800451/800783/How_To _...

URGENT - Data rate "TOO HIGH FAILURE" - BUT this isn't the two videos, it takes 9 subtitles tracks! Help, please!

I'm a standard definition DVD authoring using Encore CS6. I imported two videos high definition (1920 x 1080) (63 min and 4 min.) directly to a calendar. There are 9 subtitles.
I have converted video high-def exactly like these while encoding several times with success. I use this custom setting: Codec: MPEG2 - quality: 5 - VBR 2 pass - Progressive - Min BR: 7.2 - target BR: 8, Max BR: 9 - 23.96 EN matches source. Due to the fact that I used this predetermined dozens of times, I don't think lowering the Min, the target or the Max BR is going to solve the problem of data failure rate.
I am inclined to believe it's 9 subtitles after that review "Data rate too high failure" messages here.
As ALWAYS, I'm on a deadline to customer.

Okay, this preset has always worked in the past, but I would have thought you were pushing things with him. Subtitles can be the proverbial drop of water!

I had problems in the past with that high bit rates and also during the definition of quality to 5, instead of 4. For example, I always use 4 quality and will never more than 7 for target BR. Even with these settings, I had problems earlier this year with a chronology which contained a series of 20 JPEG images - there were always reluctant to the second jpeg, and I had to down to 6.5 before it was OK.

Have you tried a lower BR?

Reliable message of guard - performance issues - of the data?
Hello, we are on 10.2.0.3 (I know, time to upgrade, just can't right now). Data Guard is in place, in AVAILABILITY of maximum production work that was ongoing for 3 years once a week with no problems started taking 10 + hours. He used to take 2 hours Max checked, everything, nothing has changed. Ran AWR report and see that the high wait event is a RELIABLE MESSAGE:
```
Top 5 Timed Events 

Event Waits Time(s) Avg Wait(ms) % Total Call Time Wait Class 
CPU time   45,270   97.5   
*reliable message 2,655 534 201 1.1 Other*
 db file sequential read 199,278 366 2 .8 User I/O 
db file scattered read 122,914 287 2 .6 User I/O 
LGWR wait on LNS 35,511 209 6 .4 Network 
```
Is - this Data Guard? What can we do to fix this? I dropped the day before, tried to re - run this job and still have high reliable message:
```
Top 5 Timed Events 

Event Waits Time(s) Avg Wait(ms) % Total Call Time Wait Class 
CPU time   11,490   98.7   
reliable message 804 77 96 .7 Other 
db file scattered read 92,969 34 0 .3 User I/O 
db file sequential read 17,596 25 1 .2 User I/O 
log file parallel write 13,268 11 1 .1 System I/O 
```
I don't understand much about Metalink. If I dropped the day before, newspapers are not speeding it more, shouldn't that have improved performance? Or should I disable the configuration to test any scenario Data Guard in this case? In the last configuration disabeling required re-buillding DG however. Please notify. What is the reliable message? Thank you!
My bad. You are right, they are 10MB.

I have galanced bytes and somehow added an extra 0.

The 200 MB comes from the query - 'optimal_logfile_size = 201.

The rule of the 20 minutes of CKPT is good, but sometimes the databases have a peak period, which is only about half a day.

10 MB is a bit small, I consider what makes them great. At least 100 MB.

I remember you, you had the 'Data Guard - total loss of primary education"question just now.

Best regards

mseberg

Ask what moved off-topic messages
There are a number of positions that has accumulated in the Group of systems of storage and Server forums that are not on the subject for them.
They were usually posted by people who care not to read anything or explore the appropriate forum and just empty a question.
I did the routine "report abuse" on a number of them, but that appears to have been ignored.

Thus, this new post.

These are from the last 60 days:

(need to be moved on a Glassfish forum)
How to start Galssfish when the computer restarts
GlassFish 3.0.1 updatetool
http://forums.Oracle.com/forums/thread.jspa?threadID=2128052
war to change domain.xml in glassfish 3
GlassFish 2.1 + JPA 2: need expert advice of Sun/Oracle

(for Sun Java System "whatever" applications, made available to the Server forums)
AMPostAuthProcessInterface redirection problem
http://forums.Oracle.com/forums/thread.jspa?threadID=2127174
WebLogic spring/example of Application help
Cannot add new LDAP group members in Sun Java Server 7.0
http://forums.Oracle.com/forums/thread.jspa?threadID=2134347
Help with iPlanet
iText vs Jasper, Application Java Source Code
OpenMQ Unack messages'ed causing the Java heap overflow in STOMP

(product database issues assigned to the Administration of the system and hardware forums)
How can I save lock file?
Oracle for Mac
Problem using TNS_ADMIN in registry (Ora 11 g Instant client R2 in Win 7)
http://forums.Oracle.com/forums/thread.jspa?threadID=2154755
/ opt/SUNWwbsvr7/bin/WADM came out with the error: 125
Performance test tool
ORA-00202 and fracture block found during control read file header
Performance monitoring
Reg: Installation of Weblogic Server
How can export 9i to 11g
What is the problem with oracle database11g? Is it a serious problem?
Required client download link
http://forums.Oracle.com/forums/thread.jspa?threadID=2149037
Oracle 10G under Redhat Linux VMware
http://forums.Oracle.com/forums/thread.jspa?threadID=2138098
I can't connect to Oracle
What is the function of the field CanGrow dba_data_files?
http://forums.Oracle.com/forums/thread.jspa?threadID=2139323
copy of database
Advice needed regarding the practice of database design
Manager of the company
http://forums.Oracle.com/forums/thread.jspa?threadID=2128320
Problem with the granting of privileges
Inatalling IDM 11g on machine WondowsXp
Good resources for information on specifications for a new 11g install?
When installing EMCA trows an error: error loading configuration data
I received the Validation error in the backup
RMAN RESTORE
Find the users in a database using more CPU
Oracle 10g 64 bit database error of Windows 2008 R2 (64-bit)?
http://forums.Oracle.com/forums/thread.jspa?threadID=1554073
Not cleared temporary tablespace
TNS-12541-TNS: no listener
Installation of Oracle 11 g on a server without network access
RMAN displays the following error... Please can someone help me...
http://forums.Oracle.com/forums/thread.jspa?threadID=2137784
java.lang.Exception
http://forums.Oracle.com/forums/thread.jspa?threadID=2138186
ORA-12543 instance when creating a new oracle, Oracle 11 g
Problem with uninstalling Oracle 11.2 on Windows Server 2008
mod_plsql oracle 11g linux installation problem
Best practices to install oracle 11g r2 on Windows Server 2008 r2
ORA-12535: TNS:operation expired
http://forums.Oracle.com/forums/thread.jspa?threadID=1982259
move the file to data/tablespace in a partitioned table
Orace installation of CRS 11 g (64-bit windows server 2008) error
DataPump importing from a card reader
http://forums.Oracle.com/forums/thread.jspa?threadID=1982528
http://forums.Oracle.com/forums/thread.jspa?threadID=2126409
http://forums.Oracle.com/forums/thread.jspa?threadID=2126802
Oracle layout power switch with SQLPLUS and ORADIM Windows...
http://forums.Oracle.com/forums/thread.jspa?threadID=1574872
http://forums.Oracle.com/forums/thread.jspa?threadID=2123572
http://forums.Oracle.com/forums/thread.jspa?threadID=2041227
http://forums.Oracle.com/forums/thread.jspa?threadID=2077085
http://forums.Oracle.com/forums/thread.jspa?threadID=2069660
rukbat wrote:

PhHein says:

management of the Forum are working on a solution
to allow us to move/delete somewhere else.
In the meantime, we can only wait.

Thank you for the activity report.

Now! I did some cleaning and have moved the most recent threads (this year) to the Oracle DB forums. Keep the reports here or in the thread of abuse in JP.

Phil

Problem with message on glassfish 3.0.1
Hello
I try to send groups of messages using the JMSXGroupId properties, but I is unable to archieve the result I want: when I start 2 receiver of messages in a queue, messages are captured by an auditor or another doesn't matter, whether or not they are met.

Could someone explain to me why?

I use glassfish JMS implementation and the following classes

-Utility class-
Import javax.jms.Connection;
Import javax.jms.ConnectionFactory;
Import javax.jms.JMSException;
Import javax.jms.Queue;
Import javax.jms.Session;
Import javax.naming.InitialContext;
Import javax.naming.NamingException;
Public MustInherit class GenericJMS {}

protected ConnectionFactory connectionFactory = null;
protected connection = null;
protected a session = null;
protégé of queue queue = null;

protected void initJndiConnection() throws NamingException, JMSException {}
InitialContext jndiContext = new world;
connectionFactory = (ConnectionFactory) jndiContext.lookup ("jms. LorJUGQCF");
connection = connectionFactory.createConnection ();
session = connection.createSession (false, Session.AUTO_ACKNOWLEDGE);
queue = jndiContext.lookup ("jms.jms.LorJugP2p") (line);
}

Public Sub initConnection (boolean useJndi) throws Exception {}
If {(useJndi)
initJndiConnection();
} else {}
initDirectConnection();
}
specificInit();
}

protected void initDirectConnection() throws Exception {}
connectionFactory = new com.sun.messaging.ConnectionFactory ();
connection = connectionFactory.createConnection ();
session = connection.createSession (false, Session.AUTO_ACKNOWLEDGE);
queue = session.createQueue ("jms.jms.LorJugP2p");
}

protected void closeConnection() throws Exception {}
Connection.Close;
}

protected abstract Sub specificInit() throws Exception;
}

-Listener-
import java.util.logging.Level;
to import java.util.logging.Logger;
Import javax.jms.Message;
to import javax.jms.MessageListener;
to import javax.jms.TextMessage;

/ public class ContinuousReceiver implements MessageListener {}

String ID;

public ContinuousReceiver (String id) {}
This.ID = id;
}

{} public void onMessage (Message msg)
try {}
TextMessage tm = msg (text);
System.out.printf ("%s listener receive message %s\n", id, tm.getText ());
} catch (Exception ex) {}
Logger.getLogger (ContinuousReceiver.class.getName ()) .log (Level.SEVERE, null, ex);
}
}

}

-Earphone Launcher-
Import javax.jms.MessageConsumer;

SerializableAttribute public class ContinuousListenerDemo extends GenericJMS {}

MessageConsumer msgConsumer = null;
Receiver ContinuousReceiver;

@Override
protected void specificInit() throws Exception {}
msgConsumer = session.createConsumer (tail);
receiver = new ContinuousReceiver ("receiver");
msgConsumer.setMessageListener (receiver);
Connection.Start ();
}

Public Shared Sub main (String... args) throws Exception {}
Demo ContinuousListenerDemo = new ContinuousListenerDemo();
demo.initConnection (false);
Thread.currentThread () .join ();
demo.closeConnection ();
}
}

-The sender of the message group-

to import java.util.Enumeration;
import java.util.Random;
Import javax.jms.ConnectionMetaData;
Import javax.jms.JMSException;
Import javax.jms.MessageProducer;
to import javax.jms.TextMessage;

SerializableAttribute public class GroupSender extends GenericJMS {}

MessageProducer producer = null;

@Override
protected void specificInit() throws Exception {}
producer = session.createProducer (tail);
}

Public Shared Sub main (String [] args) throws Exception {}
GroupSender gs = new GroupSender();
gs.initConnection (false);

ConnectionMetaData metadata = gs.connection.getMetaData ();
Enumeration e = metaData.getJMSXPropertyNames ();
While (e.hasMoreElements ()) {}
String jmsxPropertyName = (String) e.nextElement ();
System.out.println (jmsxPropertyName);
}

gs.sendGroup (10, 5);
gs.closeConnection ();
}

' private void sendGroup (int numberOfGroups, int maxGroupSize) throws JMSException {}
Random r = new Random();
for (int i = 0; i < numberOfGroups; i ++) {}
int toSend = 1 + r.nextInt (maxGroupSize);
String groupName = Integer.toString (i);
for (int j = 0; j < toSend; j ++) {}
TextMessage tm = session.createTextMessage ();
tm.setText (String.format ("%d/%d message %d group", j + 1, toSend, i));
tm.setStringProperty ("JMSXGroupID", groupName);
tm.setIntProperty ("JMSXGroupSeq", j);
Producer.Send (TM);
}
}
}
}

-Output obtained when I run 2 - ContinuousListenerDemo
Auditeur1:
Earpiece receiver receive message 1/2 group 0
Earpiece receiver receive message 1/5 Group 1
Earpiece receiver receive message message 3/5 Group 1
Earpiece receiver receive message message 5/5 Group 1
Earpiece receiver receive message 4/5 group 2
Earpiece receiver receive message message 5/5 group 2
Earpiece receiver receive message 1/2 Group 3
Earpiece receiver receive message 1/2 Group 4
Earpiece receiver receive message 1/4 group 5
Earpiece receiver receive message 2/4 group 5
Earpiece receiver receive message message 3/4 group 5
Earpiece receiver receive message message 5/5 Group 6
Earpiece receiver receive message 2/2 Group 7
Earpiece receiver receive message 2/4 group 8
Earpiece receiver receive message 4/4 group 8

Listener2
Earpiece receiver receive message 2/2 group 0
Earpiece receiver receive message 2/5 Group 1
Earpiece receiver receive message 4/5 Group 1
Earpiece receiver receive message 1/5 group 2
Earpiece receiver receive message 2/5 group 2
Earpiece receiver receive message message 3/5 group 2
Earpiece receiver receive message 2/2 Group 3
Earpiece receiver receive message 2/2 Group 4
Earpiece receiver receive message 4/4 group 5
Earpiece receiver receive message 1/5 of the 6 Group
Earpiece receiver receive message 2/5 of the 6 Group
Earpiece receiver receive message message 3/5 of the 6 Group
Earpiece receiver receive message 4/5 of the 6 Group
Earpiece receiver receive message 1/2 Group 7
Earpiece receiver receive message 1/4 group 8
Earpiece receiver receive message message 3/4 group 8
Earpiece receiver receive message 1/1 Group 9

Edited by: user4473416 Dec 13. 2010 11:55
The JMS specification specifies that the JMS provider should do something with another JMSXGroupID that allow to be set and retrieved. So that's all GlassFish MQ don't.

If you want a particular consumer to receive only messages that have specific JMSXGroupID values so that you can use JMSXGroupID in a message selector.

Nigel

Dequeue condition causes queue sort order to be ignored
This question relates to the fact that when a dequeue condition is specified the sort order of the queue can be invoked on:
Of the 11.2 document "Introduction to Oracle QA:

"A dequeue condition is expressed in terms of message properties or the content of the message and is similar to the syntax for the WHERE clause of a SQL query." Messages in the queue are assessed based on the State and the messages that meet the given condition are returned. When using a dequeue, removed from the order of messages condition is indeterminate, and the sort order of the queue is not honored. »

I have a problem - I'm interested in consumers of respondent data certain selection criteria, but want to get this qualification given in the order of the oldest first (ENQ_TIME). If specifying the dequeue condition means that the order is unpredictable so it is not acceptable.

I recognize that I could solve the problem by using the queue MULTIPLE_CONSUMER in which subscriptions are added with the rules for each possible consumer. The problem is that the volatility of the pool of consumption is relatively high and a solution is sought requires no adjustment properties of the queue.

Am I missing something? i.e. misinterpretting this restriction?
Someone else took up this challenge and found a technique to solve this problem?

Thank you in advance.
Hello

The note needs modified to indicate that the event changes how dequeue via a deq_condition or done by the works of correlation id by adding another order by clause. If the 'impact' performance is localized to these stops and nothing else.

There are a number of customers who have implemented this in production environments and are perfectly happy with it. Have you tried this event in a test environment?

Thank you
Peter

Questions about MDB
Hi all

This question is just based on what I observed when deploying an MDB and send messages.

Configuration:

Has deployed an MDB on Admin Server.

Comment:

Current consumption = 16
Consumer high = 16
Consumer Total = 16

Some messages sent and was able to consume these messages through the MDB successfully (no problem)

Cancelled the MDB

Current consumption = 0
Consumer high = 16
Consumer Total = 16

The MDB has deployed again

Current consumption = 16
Consumer high = 16
Consumer Total = 32

Weblogic server restart

Current consumption = 16
Consumer high = 16
Consumer Total = 16

Issues related to the:
1: Why is there 16 consumer... .is this default or we can modify them?
: 2 16 consumers, what it means at the same time, I have 16 consumer consuming or read to consume messages?
3: after the redeployment of the MDB, I observe that total consumption number is 32, this just means the total number of available consumer until Let's restart weblogic?

These issues could be very basic, but I'm pretty new to weblogic, so you'd be grateful if someone of you could share your knowledge with me.

Thank you
Stacey.

Published by: stacey on 7 Sep 2010 17:44

Published by: stacey on 7 Sep 2010 17:47
1: Why is there 16 consumer... .is this default or we can modify them?

It is the default value. See chapter MDB of the Performance Tuning guide to change:

http://download.Oracle.com/docs/CD/E14571_01/Web.1111/e13814/mdbtuning.htm#PERFM271

: 2 16 consumers, what it means at the same time, I have 16 consumer consuming or read to consume messages?

Yes.

3: after the redeployment of the MDB, I observe that total consumption number is 32, this just means the total number of available consumer until Let's restart weblogic?

N ° it simply means a total of 32 consumer have been created, 16 of them have been closed when you redeployed, and 16 are open ("current").

Kind regards

Tom

HP probook 450 g1: route power hp probook 450 g1

I'm here to ask a question about the road that the flow of electrons inside my question computer.this is intended for professionals from the hardware store. When I plug my laptop, does the power:

(a) goes to the battery and the laptop is powered from the battery

or

(b) divides into 2 courses, a turn on the computer, the other charges the battery and the computer is not drawing power (or draws less power) battery

or

(c) other. Please explain

I ask this question because as you know, the battery is lithium-ion, and it has a limited number of cycles (full charge of the battery is a cycle, charge 1 / x battery is 1 / x of a cycle). When the battery reaches this limited amount of the cycle, it will start to deteriorate, taking less fresh and possibly output low voltage. Since I am a hardcore gamer (I know many of you yelling at me because using a computer laptop, no, let me correct that: a portable desktop overpriced for play games, but I had no idea of the game in mind when I bought it.) However, it can still play a lot of current gen and gen following some games on low or medium setting). so when I am gaming, this battery can drop from 100% to 10% in just 30 minutes. and given that I spend anywhere from 5 to 12 hours a day game on weekends and about 1 week, so power consumption is quite high.

If the answer to the above question is, my battery is pretty f * ed (I know that the battery on this laptop is easy to remove, but I will not remove a lot because the last of them is probably due to a problem with removing the battery regularly, but I don't see any damage that could be done to the battery if it is removed on a regular basis).

But if the answer to the above question is B, then my battery will be complete very well because not many cycles will be used, as opposed to A that will completely destroy the number of cycle.

and if the answer is C, then explain it please and if possible, tell me what effect this will have on the battery.

Hey there,

do not know the technical details, but I have a G1 450 myself and I also do some game. It is now about a year and a half and I have mostly kept the inserted battery, because A it does not heat even when the rest of the system doesn't and B, it seems that load MCE circuit leaves only when it detects its fully charged. He did not lose a large part of its load, because I use especially the pc connected to the AC adapter and the battery does not several cycles. The number of cycles of battery check confirms it.

So you shouldn't really be a problem prevents the battery where it is. But if you do a lot of game, remember to use a can of compressed air to clean the air openings regularly.

See you soon

Consumption consume slowly - high UNACK message

Similar Questions

Maybe you are looking for