Added setter for MessageFactory to TP

belaban · Jan 27, 2021 · 29e439f · 29e439f
1 parent 0a576fe
commit 29e439f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/org/jgroups/protocols/TP.java b/src/org/jgroups/protocols/TP.java
@@ -270,6 +270,7 @@ public <T extends TP> T setMaxBundleSize(int size) {
     public <T extends TP> T setBundlerCapacity(int c)           {this.bundler_capacity=c; return (T)this;}
     public int              getMessageProcessingMaxBufferSize() {return msg_processing_max_buffer_size;}
     public MessageFactory   getMessageFactory()                 {return msg_factory;}
+    public <T extends TP> T setMessageFactory(MessageFactory m) {msg_factory=m; return (T)this;}
     public boolean          useFibers()                         {return use_fibers;}
 
     public InetAddress getBindAddr() {return bind_addr;}
@@ -349,7 +350,7 @@ public <T extends TP> T setDiagnosticsPort(int d) {
     public long getSuppressTimeDifferentClusterWarnings() {return suppress_time_different_cluster_warnings;}
     public <T extends TP> T setSuppressTimeDifferentClusterWarnings(long s) {this.suppress_time_different_cluster_warnings=s; return (T)this;}
 
-    public String getMsgFactoryClass() {return msg_factory_class;}
+    public String           getMsgFactoryClass()         {return msg_factory_class;}
     public <T extends TP> T setMsgFactoryClass(String m) {this.msg_factory_class=m; return (T)this;}
 
     public String getBundlerType() {return bundler_type;}