[JBoss Cache: Core Edition] - Using TCP to do clustering
by tariksingh
Hi,
I am using TCP to setup a jboss cache cluster. I have modified the demo-cache-config.xml in jbosscache-demo-1.0.BETA1 to detect the other jboss caches. For this I specified the address of my both the machines in mcast_addr to 10.1.200.129, which is the IP of one of my machines. When I launched the demo on both the applications they could not detect each other. The view in the control panel also shows the UDP version of the xml.
I cannot use the UDP protocol.
Please find attached the config xml.
<?xml version="1.0" encoding="UTF-8"?>
<!-- ===================================================================== -->
<!-- -->
<!-- Sample TreeCache Service Configuration -->
<!-- -->
<!-- ===================================================================== -->
<!-- ==================================================================== -->
<!-- Defines TreeCache configuration -->
<!-- ==================================================================== -->
jboss:service=Naming
jboss:service=TransactionManager
<!--
Configure the TransactionManager
-->
org.jboss.cache.transaction.GenericTransactionManagerLookup
<!--
Isolation level : SERIALIZABLE
REPEATABLE_READ (default)
READ_COMMITTED
READ_UNCOMMITTED
NONE
-->
REPEATABLE_READ
<!--
Valid modes are LOCAL
REPL_ASYNC
REPL_SYNC
INVALIDATION_ASYNC
INVALIDATION_SYNC
-->
REPL_SYNC
<!--
Just used for async repl: use a replication queue
-->
false
<!--
Replication interval for replication queue (in ms)
-->
0
<!--
Max number of elements which trigger replication
-->
0
<!-- Name of cluster. Needs to be the same for all TreeCache nodes in a
cluster in order to find each other.
-->
JBossCache-Cluster
<!--Uncomment next three statements to enable JGroups multiplexer.
This configuration is dependent on the JGroups multiplexer being
registered in an MBean server such as JBossAS. -->
jgroups.mux:name=Multiplexer
jgroups.mux:name=Multiplexer
fc-fast-minimalthreads
<!-- JGroups protocol stack properties.
ClusterConfig isn't used if the multiplexer is enabled and successfully initialized.
-->
<TCP recv_buf_size="20000000" use_send_queues="false"
loopback="false"
discard_incompatible_packets="true"
max_bundle_size="64000"
max_bundle_timeout="30"
use_incoming_packet_handler="true"
enable_bundling="true"
enable_unicast_bundling="true"
enable_diagnostics="true"
use_concurrent_stack="true"
thread_naming_pattern="pl"
thread_pool.enabled="true"
thread_pool.min_threads="1"
thread_pool.max_threads="4"
thread_pool.keep_alive_time="30000"
thread_pool.queue_enabled="true"
thread_pool.queue_max_size="50000"
thread_pool.rejection_policy="discard"
oob_thread_pool.enabled="true"
oob_thread_pool.min_threads="2"
oob_thread_pool.max_threads="4"
oob_thread_pool.keep_alive_time="10000"
oob_thread_pool.queue_enabled="false"
oob_thread_pool.queue_max_size="10"
oob_thread_pool.rejection_policy="Run"/>
<!--<PING timeout="2000" num_initial_members="3"/>-->
<MPING mcast_addr="10.1.200.129" timeout="2000" num_initial_members="3"/>
<MERGE2 max_interval="30000" min_interval="10000"/>
<FD_SOCK/>
<FD timeout="10000" max_tries="5" shun="true"/>
<VERIFY_SUSPECT timeout="1500"/>
<pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
retransmit_timeout="300,600,1200,2400,4800"
discard_delivered_msgs="true"/>
<!---->
<pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
max_bytes="400000"/>
<pbcast.GMS print_local_addr="true" join_timeout="5000"
join_retry_timeout="2000" shun="false"
view_bundling="true" view_ack_collection_timeout="5000"/>
<FC max_credits="5000000"
min_threshold="0.20"/>
<FRAG2 frag_size="60000"/>
<pbcast.STREAMING_STATE_TRANSFER use_reading_thread="true"/>
<!-- <pbcast.STATE_TRANSFER/> -->
<pbcast.FLUSH timeout="0"/>
<!--
Whether or not to fetch state on joining a cluster
NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
-->
true
<!--
The max amount of time (in milliseconds) we wait until the
state (ie. the contents of the cache) are retrieved from
existing members in a clustered environment
-->
15000
<!--
Number of milliseconds to wait until all responses for a
synchronous call have been received.
-->
15000
<!-- Max number of milliseconds to wait for a lock acquisition -->
10000
<!-- Buddy Replication config -->
true
<!-- these are the default values anyway -->
org.jboss.cache.buddyreplication.NextMemberBuddyLocator
<!-- numBuddies is the number of backup nodes each node maintains. ignoreColocatedBuddies means that
each node will *try* to select a buddy on a different physical host. If not able to do so though,
it will fall back to colocated nodes. -->
numBuddies = 10
ignoreColocatedBuddies = true
<!-- A way to specify a preferred replication group. If specified, we try and pick a buddy why shares
the same pool name (falling back to other buddies if not available). This allows the sysdmin to hint at
backup buddies are picked, so for example, nodes may be hinted topick buddies on a different physical rack
or power supply for added fault tolerance. -->
myBuddyPoolReplicationGroup
<!-- communication timeout for inter-buddy group organisation messages (such as assigning to and removing
from groups -->
2000
<!-- the following three elements, all relating to data gravitation, default to false -->
<!-- Should data gravitation be attempted whenever there is a cache miss on finding a node?
If false, data will only be gravitated if an Option is set enabling it -->
false
<!-- removes data on remote caches' trees and backup subtrees when gravitated to a new data owner -->
true
<!-- search backup subtrees as well for data when gravitating. Results in backup nodes being able to
answer data gravitation requests. -->
true
<!--
Indicate whether to use region based marshalling or not. Set this to true if you are running under a scoped
class loader, e.g., inside an application server. Default is "false".
-->
false
<!-- Uncomment to get a graphical view of the TreeCache MBean above -->
<!-- -->
<!-- jboss.cache:service=TreeCache-->
<!-- jboss.cache:service=TreeCache-->
<!-- -->
Please suggest what am I doing worng here.
Thanks in advance
Tarik
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4170194#4170194
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4170194
17 years, 11 months
[JBoss Messaging] - Classloader issues when running Mule in JBoss
by rramaiah
Hi,
I am using Mule to pull objects off of a JMS queue and I get a "classloader not found for" error. I've set the Java2ClassLoadingCompliance flag to true to make some of my other code work, so I'm not sure if that has something to do with it. Can't set it to false or my code won't startup. I have confirmed that the Audit object it is complaining about is definitely in a JAR in the WAR that is running Mule. Ideas? Thanks!
Oh, and by the way, this only happens when I'm running the app WAR and the Mule WAR on separate machines. When they're on the same machine, talking to each other through a localhost JNDI lookup, everything works fine. Again, I have confirmed that the Audit object in question exists in BOTH wars. I'm using JBoss 4.3 EAP and Mule 2.0.
********************************************************************************
| Message : No ClassLoaders found for: com.XXX.audit.beans.Audit (java.lang.RuntimeException)
| Type : org.mule.api.transformer.TransformerException
| Code : MULE_ERROR-64999
| Transformer : JMSMessageToObject{this=d438fd, name='JMSMessageToObject', ignoreBadInput=false, returnClass=class java.lang.Object, sourceTypes=[interface javax.jms.Message, interface javax.jms.TextMessage, interface javax.jms.ObjectMessage, interface javax.jms.BytesMessage, interface javax.jms.MapMessage, interface javax.jms.StreamMessage]}
| JavaDoc : http://mule.mulesource.org/docs/apidocs/org/mule/api/transformer/Transfor...
| ********************************************************************************
| Exception stack is:
| 1. No ClassLoaders found for: com.XXX.audit.beans.Audit (java.lang.RuntimeException)
| org.jboss.mx.loading.LoadMgr3:306 (http://java.sun.com/j2se/1.5.0/docs/api/java/lang/RuntimeException.html)
| 2. No ClassLoaders found for: com.XXX.audit.beans.Audit (java.lang.RuntimeException) (org.mule.api.transformer.TransformerException)
| org.mule.transport.jms.transformers.AbstractJmsTransformer:150 (http://mule.mulesource.org/docs/apidocs/org/mule/api/transformer/Transfor...)
| ********************************************************************************
| Root Exception stack trace:
| java.lang.RuntimeException: No ClassLoaders found for: com.XXX.audit.beans.Audit
| at org.jboss.mx.loading.LoadMgr3.beginLoadTask(LoadMgr3.java:306)
| at org.jboss.mx.loading.RepositoryClassLoader.loadClassImpl(RepositoryClassLoader.java:514)
| at org.jboss.mx.loading.RepositoryClassLoader.loadClass(RepositoryClassLoader.java:408)
| at java.lang.ClassLoader.loadClass(ClassLoader.java:251)
| at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:319)
| at java.lang.Class.forName0(Native Method)
| at java.lang.Class.forName(Class.java:242)
| at java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:585)
| at org.jboss.messaging.util.ObjectInputStreamWithClassLoader.resolveClass(ObjectInputStreamWithClassLoader.java:78)
| at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1544)
| at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1466)
| at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1699)
| at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1305)
| at java.io.ObjectInputStream.readObject(ObjectInputStream.java:348)
| at org.jboss.messaging.util.StreamUtils.readObject(StreamUtils.java:154)
| at org.jboss.messaging.core.impl.message.MessageSupport.getPayload(MessageSupport.java:246)
| at org.jboss.jms.message.JBossObjectMessage.getObject(JBossObjectMessage.java:125)
| at org.jboss.jms.message.ObjectMessageProxy.getObject(ObjectMessageProxy.java:64)
| at org.mule.transport.jms.JmsMessageUtils.toObject(JmsMessageUtils.java:159)
| at org.mule.transport.jms.transformers.AbstractJmsTransformer.transformFromMessage(AbstractJmsTransformer.java:146)
| at org.mule.transport.jms.transformers.JMSMessageToObject.transform(JMSMessageToObject.java:63)
| at org.mule.transformer.AbstractMessageAwareTransformer.doTransform(AbstractMessageAwareTransformer.java:68)
| at org.mule.transformer.AbstractTransformer.transform(AbstractTransformer.java:254)
| at org.mule.DefaultMuleMessage.applyAllTransformers(DefaultMuleMessage.java:564)
| at org.mule.DefaultMuleMessage.applyTransformers(DefaultMuleMessage.java:524)
| at org.mule.DefaultMuleMessage.applyTransformers(DefaultMuleMessage.java:517)
| at org.mule.DefaultMuleEvent.transformMessage(DefaultMuleEvent.java:310)
| at org.mule.DefaultMuleEvent.transformMessage(DefaultMuleEvent.java:305)
| at org.mule.routing.inbound.ForwardingConsumer.process(ForwardingConsumer.java:49)
| at org.mule.routing.inbound.DefaultInboundRouterCollection.route(DefaultInboundRouterCollection.java:89)
| at org.mule.transport.AbstractMessageReceiver$DefaultInternalMessageListener.onMessage(AbstractMessageReceiver.java:604)
| at org.mule.transport.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:346)
| at org.mule.transport.AbstractReceiverWorker$1.doInTransaction(AbstractReceiverWorker.java:114)
| at org.mule.transaction.TransactionTemplate.execute(TransactionTemplate.java:112)
| at org.mule.transport.AbstractReceiverWorker.doRun(AbstractReceiverWorker.java:131)
| at org.mule.transport.AbstractReceiverWorker.run(AbstractReceiverWorker.java:62)
| at org.mule.work.WorkerContext.run(WorkerContext.java:310)
| at org.mule.work.SyncWorkExecutor.doExecute(SyncWorkExecutor.java:41)
| at org.mule.work.MuleWorkManager.executeWork(MuleWorkManager.java:269)
| at org.mule.work.MuleWorkManager.doWork(MuleWorkManager.java:157)
| at org.mule.transport.jms.MultiConsumerJmsMessageReceiver$SubReceiver.onMessage(MultiConsumerJmsMessageReceiver.java:264)
| at org.jboss.jms.client.container.ClientConsumer.callOnMessage(ClientConsumer.java:159)
| at org.jboss.jms.client.container.ClientConsumer$ListenerRunner.run(ClientConsumer.java:976)
| at org.jboss.messaging.util.JBMExecutor$TCLExecutor.run(JBMExecutor.java:99)
| at EDU.oswego.cs.dl.util.concurrent.QueuedExecutor$RunLoop.run(QueuedExecutor.java:89)
| at java.lang.Thread.run(Thread.java:595)
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4170193#4170193
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4170193
17 years, 11 months
How to reduce/disable log messages?
by IceT
This seems to be a simple enough task, yet I haven't found any
instructions on how to do this. I tried to edit
default\conf\jboss-log4j.xml, but that doesn't help a lot. For example,
I set org.jboss.system.server.Server to ERROR, and still I get INFO
messages. I know this is one of the log4j files being used, because if
it has any invalid configuration, an error message will show up in the
console.
thanks
17 years, 11 months
