diff options
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java index c3279d994c9..19d3b5b3e43 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -14,6 +14,7 @@ import com.yahoo.messagebus.routing.RoutingPolicy; import com.yahoo.messagebus.routing.RoutingSpec; import com.yahoo.messagebus.routing.RoutingTable; import com.yahoo.messagebus.routing.RoutingTableSpec; +import com.yahoo.protect.Process; import com.yahoo.text.Utf8Array; import com.yahoo.text.Utf8String; @@ -148,8 +149,10 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, // Attach and start network. this.net = net; net.attach(this); - if ( ! net.net().waitUntilReady(120)) + if ( ! net.net().waitUntilReady(120)) { + Process.dumpThreads(); throw new IllegalStateException("Network failed to become ready in time."); + } // Start messenger. msn = new Messenger(); @@ -467,6 +470,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @return The resender. */ + @Deprecated // Remove on 9 public Resender getResender() { return resender; } @@ -477,6 +481,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @return The pending count. */ + @Deprecated // Package private on 9 public synchronized int getPendingCount() { return pendingCount; } @@ -487,6 +492,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @return The pending size. */ + @Deprecated // Package private on 9 public synchronized int getPendingSize() { return pendingSize; } @@ -497,6 +503,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @param maxCount The max count. */ + @Deprecated // Remove on 9 public void setMaxPendingCount(int maxCount) { maxPendingCount = maxCount; } @@ -505,6 +512,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * Gets maximum number of messages that can be received without being * replied to yet. */ + @Deprecated // Remove on 9 public int getMaxPendingCount() { return maxPendingCount; } @@ -515,6 +523,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @param maxSize The max size. */ + @Deprecated // Remove on 9 public void setMaxPendingSize(int maxSize) { maxPendingSize = maxSize; } @@ -523,6 +532,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * Gets maximum combined size of messages that can be received without * being replied to yet. */ + @Deprecated // Remove on 9 public int getMaxPendingSize() { return maxPendingSize; } |