[JBoss JIRA] (DROOLS-1168) notify property change
by Sante Stanisci (JIRA)
[ https://issues.jboss.org/browse/DROOLS-1168?page=com.atlassian.jira.plugi... ]
Sante Stanisci reopened DROOLS-1168:
------------------------------------
briefly describe the problem: instead of using the modify in the then condition, I need to use a custom class which changes the value. Then to notify the news to call Drools update ($entity) but this is not enough and that the rule should take cascade does not fire.
I made the following test
//not notify
then
String[] fields = new String[]{"untMisVen"};
DroolsUtil.completeEntity($entity, fields, $untMis);
update($entity)
end
-----------------
//notify but it not possible use this
then
String[] fields = new String[]{"untMisVen"};
DroolsUtil.completeEntity($entity, fields, $untMis);
$entity.setUntMisVen($entity.getUntMisVen());
update($entity)
end
I note that in update operation bitmask in case 1 is at 0 contrary to case 2 where have a value.
I attach rules and classes
> notify property change
> ----------------------
>
> Key: DROOLS-1168
> URL: https://issues.jboss.org/browse/DROOLS-1168
> Project: Drools
> Issue Type: Enhancement
> Components: core engine
> Affects Versions: 6.4.0.Final
> Environment: java 6, eclipse 4, windows 8.1
> Reporter: Sante Stanisci
> Assignee: Mario Fusco
> Priority: Critical
>
> nel then statement al posto di modify utilizzo una funzione custom per variare il campo. Questo non notifica il property change anche se la classe è annotata con @PropertyReactive
> Come posso notificare manualmente il cambiamento?
> utilizzo una stateless session
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (DROOLS-1181) NullPointerException in LogicTransformer
by Sjoerd Cranen (JIRA)
Sjoerd Cranen created DROOLS-1181:
-------------------------------------
Summary: NullPointerException in LogicTransformer
Key: DROOLS-1181
URL: https://issues.jboss.org/browse/DROOLS-1181
Project: Drools
Issue Type: Bug
Components: core engine
Affects Versions: 6.4.0.Final
Reporter: Sjoerd Cranen
Assignee: Mario Fusco
When an enum constant is used in the context of an _or_-operator as a positional argument to a query, a NullPointerException is thrown with the following stack trace:
{code}
java.lang.NullPointerException
at org.drools.core.rule.LogicTransformer.processElement(LogicTransformer.java:230)
at org.drools.core.rule.LogicTransformer.processElement(LogicTransformer.java:251)
at org.drools.core.rule.LogicTransformer.fixClonedDeclarations(LogicTransformer.java:154)
at org.drools.core.rule.LogicTransformer.transform(LogicTransformer.java:97)
at org.drools.core.definitions.rule.impl.RuleImpl.getTransformedLhs(RuleImpl.java:620)
at org.drools.core.reteoo.builder.ReteooRuleBuilder.addRule(ReteooRuleBuilder.java:108)
at org.drools.core.reteoo.ReteooBuilder.addRule(ReteooBuilder.java:106)
at org.drools.core.impl.KnowledgeBaseImpl.addRule(KnowledgeBaseImpl.java:1567)
at org.drools.core.impl.KnowledgeBaseImpl.addRule(KnowledgeBaseImpl.java:1547)
at org.drools.core.impl.KnowledgeBaseImpl.internalAddPackages(KnowledgeBaseImpl.java:920)
at org.drools.core.impl.KnowledgeBaseImpl.access$000(KnowledgeBaseImpl.java:117)
at org.drools.core.impl.KnowledgeBaseImpl$1.run(KnowledgeBaseImpl.java:708)
at org.drools.core.impl.KnowledgeBaseImpl.enqueueModification(KnowledgeBaseImpl.java:716)
at org.drools.core.impl.KnowledgeBaseImpl.addPackages(KnowledgeBaseImpl.java:705)
at org.drools.core.impl.KnowledgeBaseImpl.addKnowledgePackages(KnowledgeBaseImpl.java:273)
at org.drools.compiler.kie.builder.impl.KieContainerImpl.createKieBase(KieContainerImpl.java:510)
at org.drools.compiler.kie.builder.impl.KieContainerImpl.getKieBase(KieContainerImpl.java:447)
...
{code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (JGRP-1906) jdbc_ping doesn't delete crashed node
by Mikhail Krestyaninov (JIRA)
[ https://issues.jboss.org/browse/JGRP-1906?page=com.atlassian.jira.plugin.... ]
Mikhail Krestyaninov commented on JGRP-1906:
--------------------------------------------
Thank you!
> jdbc_ping doesn't delete crashed node
> -------------------------------------
>
> Key: JGRP-1906
> URL: https://issues.jboss.org/browse/JGRP-1906
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 3.6.1
> Environment: n/a
> Reporter: rama rama
> Assignee: Bela Ban
> Priority: Critical
>
> Hi,
> i am having trouble with jgroups. If a node crash, it doesn't get removed from jdbc table.
> After 10 hours of work, the table contains 100 rows (that is not a problem) but, when the server start_up, GMS take _AGES_ to try to connect to all this dead node.
> Since i am only a 'user' speaking about jgroup and i have no idea on how internally does it work, it this normal?
> I don't think so, master of the cluster, or a governor or something like that, should be able to detect if a node is present or not (via FD,VERIFY_SUSPECT) and delete it from JDBC table to avoid issue on startup for the next time, correct me if i am wrong.
> Here a copy/paste of my current config, configured in applicative way.
> ------------------------------------------------------------------------------------
> int min_cores = 1;
> int max_cores = 50;
> InetAddress bind_addr = org.jgroups.util.Util.getAddressByPatternMatch("match-address:" + Config.get("Cluster.bind_addr"));
> stack
> .addProtocol(new UDP()
> .setValue("bind_addr", bind_addr)
> .setValue("loopback", true)
> .setValue("thread_naming_pattern", "cl")
> .setValue("timer_type", "new3")
> .setValue("timer_min_threads", min_cores)
> .setValue("timer_max_threads", max_cores)
> .setValue("timer_keep_alive_time", Util.MIN * 10)
> .setValue("timer_queue_max_size", 500)
> .setValue("mcast_port", Config.get("Cluster.mcast_port", Constant.INT_NULL))
> .setValue("thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("thread_pool_min_threads", min_cores)
> .setValue("thread_pool_max_threads", max_cores)
> .setValue("thread_pool_queue_enabled", false)
> .setValue("thread_pool_queue_max_size", 500)
> .setValue("oob_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("oob_thread_pool_min_threads", min_cores)
> .setValue("oob_thread_pool_max_threads", max_cores)
> .setValue("oob_thread_pool_queue_enabled", false)
> .setValue("oob_thread_pool_queue_max_size", 500)
> .setValue("internal_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("internal_thread_pool_min_threads", min_cores)
> .setValue("internal_thread_pool_max_threads", max_cores)
> .setValue("internal_thread_pool_queue_enabled", false)
> .setValue("internal_thread_pool_queue_max_size", 600000)
> .setValue("ucast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("ucast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> .setValue("mcast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("mcast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> )
> .addProtocol(new JDBC_PING()
> .setValue("connection_url", Config.get("DB.dbdriver") + ':' + Config.get("DB.dburl") + '/' + Config.get("DB.dbname"))
> .setValue("connection_username", Config.get("DB.dbuser"))
> .setValue("connection_password", Config.get("DB.dbpwd"))
> .setValue("connection_driver", "org.postgresql.Driver")
> .setValue("initialize_sql", "CREATE TABLE IF NOT EXISTS JGROUPSPING ( own_addr varchar(200) NOT NULL, cluster_name varchar(200) NOT NULL, ping_data bytea DEFAULT NULL, PRIMARY KEY (own_addr, cluster_name) )")
> )
> .addProtocol(new MERGE3()
> .setValue("max_interval", 10000)
> .setValue("min_interval", 1000)
> )
> .addProtocol(new FD_SOCK()
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new FD_ALL()
> )
> .addProtocol(new VERIFY_SUSPECT()
> .setValue("timeout", 1000)
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new NAKACK2()
> .setValue("xmit_interval", 500)
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 2000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> .setValue("use_mcast_xmit", false)
> .setValue("discard_delivered_msgs", true)
> )
> .addProtocol(new UNICAST3()
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 1000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> )
> .addProtocol(new STABLE()
> .setValue("stability_delay", 2000)
> .setValue("desired_avg_gossip", 60000)
> .setValue("max_bytes", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("cap", 0.1)
> )
> .addProtocol(new GMS()
> .setValue("join_timeout", 3000)
> .setValue("view_bundling", false)
> .setValue("print_local_addr", false)
> .setValue("print_physical_addrs", false)
> )
> .addProtocol(new UFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new MFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new FRAG2()
> .setValue("frag_size", org.jgroups.util.Util.readBytesInteger("60K"))
> )
> .addProtocol(new RSVP()
> .setValue("resend_interval", 2000)
> .setValue("timeout", 10000)
> )
> ;
> stack.init();
> ----------------------------
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (JGRP-1906) jdbc_ping doesn't delete crashed node
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-1906?page=com.atlassian.jira.plugin.... ]
Bela Ban commented on JGRP-1906:
--------------------------------
Oops, my bad, forgot about that! I created https://issues.jboss.org/browse/JGRP-2064 to take care of that.
> jdbc_ping doesn't delete crashed node
> -------------------------------------
>
> Key: JGRP-1906
> URL: https://issues.jboss.org/browse/JGRP-1906
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 3.6.1
> Environment: n/a
> Reporter: rama rama
> Assignee: Bela Ban
> Priority: Critical
>
> Hi,
> i am having trouble with jgroups. If a node crash, it doesn't get removed from jdbc table.
> After 10 hours of work, the table contains 100 rows (that is not a problem) but, when the server start_up, GMS take _AGES_ to try to connect to all this dead node.
> Since i am only a 'user' speaking about jgroup and i have no idea on how internally does it work, it this normal?
> I don't think so, master of the cluster, or a governor or something like that, should be able to detect if a node is present or not (via FD,VERIFY_SUSPECT) and delete it from JDBC table to avoid issue on startup for the next time, correct me if i am wrong.
> Here a copy/paste of my current config, configured in applicative way.
> ------------------------------------------------------------------------------------
> int min_cores = 1;
> int max_cores = 50;
> InetAddress bind_addr = org.jgroups.util.Util.getAddressByPatternMatch("match-address:" + Config.get("Cluster.bind_addr"));
> stack
> .addProtocol(new UDP()
> .setValue("bind_addr", bind_addr)
> .setValue("loopback", true)
> .setValue("thread_naming_pattern", "cl")
> .setValue("timer_type", "new3")
> .setValue("timer_min_threads", min_cores)
> .setValue("timer_max_threads", max_cores)
> .setValue("timer_keep_alive_time", Util.MIN * 10)
> .setValue("timer_queue_max_size", 500)
> .setValue("mcast_port", Config.get("Cluster.mcast_port", Constant.INT_NULL))
> .setValue("thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("thread_pool_min_threads", min_cores)
> .setValue("thread_pool_max_threads", max_cores)
> .setValue("thread_pool_queue_enabled", false)
> .setValue("thread_pool_queue_max_size", 500)
> .setValue("oob_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("oob_thread_pool_min_threads", min_cores)
> .setValue("oob_thread_pool_max_threads", max_cores)
> .setValue("oob_thread_pool_queue_enabled", false)
> .setValue("oob_thread_pool_queue_max_size", 500)
> .setValue("internal_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("internal_thread_pool_min_threads", min_cores)
> .setValue("internal_thread_pool_max_threads", max_cores)
> .setValue("internal_thread_pool_queue_enabled", false)
> .setValue("internal_thread_pool_queue_max_size", 600000)
> .setValue("ucast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("ucast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> .setValue("mcast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("mcast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> )
> .addProtocol(new JDBC_PING()
> .setValue("connection_url", Config.get("DB.dbdriver") + ':' + Config.get("DB.dburl") + '/' + Config.get("DB.dbname"))
> .setValue("connection_username", Config.get("DB.dbuser"))
> .setValue("connection_password", Config.get("DB.dbpwd"))
> .setValue("connection_driver", "org.postgresql.Driver")
> .setValue("initialize_sql", "CREATE TABLE IF NOT EXISTS JGROUPSPING ( own_addr varchar(200) NOT NULL, cluster_name varchar(200) NOT NULL, ping_data bytea DEFAULT NULL, PRIMARY KEY (own_addr, cluster_name) )")
> )
> .addProtocol(new MERGE3()
> .setValue("max_interval", 10000)
> .setValue("min_interval", 1000)
> )
> .addProtocol(new FD_SOCK()
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new FD_ALL()
> )
> .addProtocol(new VERIFY_SUSPECT()
> .setValue("timeout", 1000)
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new NAKACK2()
> .setValue("xmit_interval", 500)
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 2000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> .setValue("use_mcast_xmit", false)
> .setValue("discard_delivered_msgs", true)
> )
> .addProtocol(new UNICAST3()
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 1000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> )
> .addProtocol(new STABLE()
> .setValue("stability_delay", 2000)
> .setValue("desired_avg_gossip", 60000)
> .setValue("max_bytes", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("cap", 0.1)
> )
> .addProtocol(new GMS()
> .setValue("join_timeout", 3000)
> .setValue("view_bundling", false)
> .setValue("print_local_addr", false)
> .setValue("print_physical_addrs", false)
> )
> .addProtocol(new UFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new MFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new FRAG2()
> .setValue("frag_size", org.jgroups.util.Util.readBytesInteger("60K"))
> )
> .addProtocol(new RSVP()
> .setValue("resend_interval", 2000)
> .setValue("timeout", 10000)
> )
> ;
> stack.init();
> ----------------------------
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (JGRP-2064) JDBC_PING: make subclass of FILE_PING
by Bela Ban (JIRA)
Bela Ban created JGRP-2064:
------------------------------
Summary: JDBC_PING: make subclass of FILE_PING
Key: JGRP-2064
URL: https://issues.jboss.org/browse/JGRP-2064
Project: JGroups
Issue Type: Feature Request
Reporter: Bela Ban
Assignee: Bela Ban
Priority: Minor
Fix For: 3.6.10, 4.0
This way, zombie removal would be possible, e.g. attributes {{remove_old_coords_on_view_change}} and {{remove_all_files_on_view_change}} would be usable.
Currently, JDBC_PING extends Discovery only, not FILE_PING
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (WFCORE-1558) read-children-names on server-group deployments returns empty list, when it should just DTRT and return a list
by Harald Pehl (JIRA)
[ https://issues.jboss.org/browse/WFCORE-1558?page=com.atlassian.jira.plugi... ]
Harald Pehl commented on WFCORE-1558:
-------------------------------------
Currently we do not use {{/server-group=*/:read-children-names(child-type=deployment)}}. We only use it on a specific server-group like {{/server-group=main-server-group/:read-children-names(child-type=deployment)}}. So changing this should not have an impact on the console.
I've noticed similar issues when invoking the {{read-children-names}} using wildcards:
- {{/socket-binding-group=\*/socket-binding=\*:read-resource}} → list of resources
- {{/socket-binding-group=\*:read-children-names(child-type=socket-binding)}} → empty list
and
- {{/core-service=management/access=authorization/role-mapping=\*/include=\*:read-resource}} → list of resources
- {{/core-service=management/access=authorization/role-mapping=\*:read-children-resources(child-type=include)}} → empty list
So seems to be a general issue in {{AbstractMultiTargetHandler}}?
> read-children-names on server-group deployments returns empty list, when it should just DTRT and return a list
> --------------------------------------------------------------------------------------------------------------
>
> Key: WFCORE-1558
> URL: https://issues.jboss.org/browse/WFCORE-1558
> Project: WildFly Core
> Issue Type: Bug
> Reporter: Ken Wills
> Assignee: Ken Wills
>
> Using a wildcard :read-children-names on deployments returns an empty list, when it should probably just return an error, or the right answer ;)
> See OperationContextImpl.readResourceFromRoot for /server-group=*
> The OSHs are based on AbstractMultiTargetHandler.
> Output should be something like:
> {
> "outcome" => "success",
> "result" => [
> {
> "address" => [("server-group" => "main-server-group")],
> "outcome" => "success",
> "result" => ["simple-servlet.war"]
> }
> },
> {
> "address" => [("server-group" => "other-server-group")],
> "outcome" => "success",
> "result" =>
> "result" => ["simple-servlet.war"]
> }
> ]
> }
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months
[JBoss JIRA] (JGRP-1906) jdbc_ping doesn't delete crashed node
by Mikhail Krestyaninov (JIRA)
[ https://issues.jboss.org/browse/JGRP-1906?page=com.atlassian.jira.plugin.... ]
Mikhail Krestyaninov commented on JGRP-1906:
--------------------------------------------
The problem here is JDBC_PING isn't a subclass of FILE_PING :) Using FILE_PING in a cluster assumes having a network FS, which I don't have - that's why JDBC_PING was my choice.
> jdbc_ping doesn't delete crashed node
> -------------------------------------
>
> Key: JGRP-1906
> URL: https://issues.jboss.org/browse/JGRP-1906
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 3.6.1
> Environment: n/a
> Reporter: rama rama
> Assignee: Bela Ban
> Priority: Critical
>
> Hi,
> i am having trouble with jgroups. If a node crash, it doesn't get removed from jdbc table.
> After 10 hours of work, the table contains 100 rows (that is not a problem) but, when the server start_up, GMS take _AGES_ to try to connect to all this dead node.
> Since i am only a 'user' speaking about jgroup and i have no idea on how internally does it work, it this normal?
> I don't think so, master of the cluster, or a governor or something like that, should be able to detect if a node is present or not (via FD,VERIFY_SUSPECT) and delete it from JDBC table to avoid issue on startup for the next time, correct me if i am wrong.
> Here a copy/paste of my current config, configured in applicative way.
> ------------------------------------------------------------------------------------
> int min_cores = 1;
> int max_cores = 50;
> InetAddress bind_addr = org.jgroups.util.Util.getAddressByPatternMatch("match-address:" + Config.get("Cluster.bind_addr"));
> stack
> .addProtocol(new UDP()
> .setValue("bind_addr", bind_addr)
> .setValue("loopback", true)
> .setValue("thread_naming_pattern", "cl")
> .setValue("timer_type", "new3")
> .setValue("timer_min_threads", min_cores)
> .setValue("timer_max_threads", max_cores)
> .setValue("timer_keep_alive_time", Util.MIN * 10)
> .setValue("timer_queue_max_size", 500)
> .setValue("mcast_port", Config.get("Cluster.mcast_port", Constant.INT_NULL))
> .setValue("thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("thread_pool_min_threads", min_cores)
> .setValue("thread_pool_max_threads", max_cores)
> .setValue("thread_pool_queue_enabled", false)
> .setValue("thread_pool_queue_max_size", 500)
> .setValue("oob_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("oob_thread_pool_min_threads", min_cores)
> .setValue("oob_thread_pool_max_threads", max_cores)
> .setValue("oob_thread_pool_queue_enabled", false)
> .setValue("oob_thread_pool_queue_max_size", 500)
> .setValue("internal_thread_pool_keep_alive_time", Util.MIN * 10)
> .setValue("internal_thread_pool_min_threads", min_cores)
> .setValue("internal_thread_pool_max_threads", max_cores)
> .setValue("internal_thread_pool_queue_enabled", false)
> .setValue("internal_thread_pool_queue_max_size", 600000)
> .setValue("ucast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("ucast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> .setValue("mcast_recv_buf_size", org.jgroups.util.Util.readBytesInteger("5M"))
> .setValue("mcast_send_buf_size", org.jgroups.util.Util.readBytesInteger("640K"))
> )
> .addProtocol(new JDBC_PING()
> .setValue("connection_url", Config.get("DB.dbdriver") + ':' + Config.get("DB.dburl") + '/' + Config.get("DB.dbname"))
> .setValue("connection_username", Config.get("DB.dbuser"))
> .setValue("connection_password", Config.get("DB.dbpwd"))
> .setValue("connection_driver", "org.postgresql.Driver")
> .setValue("initialize_sql", "CREATE TABLE IF NOT EXISTS JGROUPSPING ( own_addr varchar(200) NOT NULL, cluster_name varchar(200) NOT NULL, ping_data bytea DEFAULT NULL, PRIMARY KEY (own_addr, cluster_name) )")
> )
> .addProtocol(new MERGE3()
> .setValue("max_interval", 10000)
> .setValue("min_interval", 1000)
> )
> .addProtocol(new FD_SOCK()
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new FD_ALL()
> )
> .addProtocol(new VERIFY_SUSPECT()
> .setValue("timeout", 1000)
> .setValue("bind_addr", bind_addr)
> )
> .addProtocol(new NAKACK2()
> .setValue("xmit_interval", 500)
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 2000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> .setValue("use_mcast_xmit", false)
> .setValue("discard_delivered_msgs", true)
> )
> .addProtocol(new UNICAST3()
> .setValue("xmit_table_num_rows", 100)
> .setValue("xmit_table_msgs_per_row", 1000)
> .setValue("xmit_table_max_compaction_time", 30000)
> .setValue("max_msg_batch_size", 500)
> )
> .addProtocol(new STABLE()
> .setValue("stability_delay", 2000)
> .setValue("desired_avg_gossip", 60000)
> .setValue("max_bytes", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("cap", 0.1)
> )
> .addProtocol(new GMS()
> .setValue("join_timeout", 3000)
> .setValue("view_bundling", false)
> .setValue("print_local_addr", false)
> .setValue("print_physical_addrs", false)
> )
> .addProtocol(new UFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new MFC()
> .setValue("max_credits", org.jgroups.util.Util.readBytesInteger("4M"))
> .setValue("min_threshold", 0.4)
> )
> .addProtocol(new FRAG2()
> .setValue("frag_size", org.jgroups.util.Util.readBytesInteger("60K"))
> )
> .addProtocol(new RSVP()
> .setValue("resend_interval", 2000)
> .setValue("timeout", 10000)
> )
> ;
> stack.init();
> ----------------------------
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 11 months