Package com.tnsai.protocols.handlers

Class DebateProtocolHandler

java.lang.Object

com.tnsai.protocols.handlers.AbstractProtocolHandler

com.tnsai.protocols.handlers.DebateProtocolHandler

All Implemented Interfaces:

ProtocolHandler

public final class DebateProtocolHandler
extends AbstractProtocolHandler

Handler for multi-agent debate and consensus building protocol.

Supports:

• Round-based discussions with configurable max rounds
• Opinion/position submission with confidence scores
• Voting and counter-arguments
• Multiple consensus strategies (majority, supermajority, unanimous, weighted)
• Automatic deadlock detection

Thread-safe implementation for concurrent multi-agent debates.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DebateProtocolHandler.ConsensusResult	Result of consensus check.
static class	DebateProtocolHandler.DebateSession	Represents an active debate session.
static enum	DebateProtocolHandler.DebateStatus	Debate status.
static class	DebateProtocolHandler.Position	Agent position in a debate.
static class	DebateProtocolHandler.RoundSnapshot	Snapshot of a completed round.

Nested classes/interfaces inherited from interface com.tnsai.protocols.handlers.ProtocolHandler

ProtocolHandler.HandlerCallback, ProtocolHandler.HandlerException

Constructor Summary

Constructors

Constructor	Description
DebateProtocolHandler(Transport transport, int maxRounds, double consensusThreshold, com.tnsai.protocols.annotations.Debate.ConsensusStrategy strategy, long roundTimeoutMs)

Method Summary

Modifier and Type	Method	Description
List<DebateProtocolHandler.DebateSession>	getActiveDebates()	Gets all active debates.
DebateProtocolHandler.DebateSession	getDebate(String debateId)	Gets an active debate session.
com.tnsai.protocols.models.Message	send(com.tnsai.protocols.models.Message message)	Sends a message using this protocol.
void	sendAsync(com.tnsai.protocols.models.Message message, ProtocolHandler.HandlerCallback callback)	Sends a message asynchronously.
DebateProtocolHandler.DebateSession	startDebate(String topic, com.tnsai.protocols.models.AgentEndpoint initiator, List<String> participants)	Starts a new debate.
void	submitCounterArgument(String debateId, com.tnsai.protocols.models.AgentEndpoint sender, String targetAgent, String counterArgument, String alternative)	Submits a counter-argument.
void	submitPosition(String debateId, com.tnsai.protocols.models.AgentEndpoint sender, String stance, int confidence, String reasoning)	Submits a position/opinion for the current round.
void	vote(String debateId, com.tnsai.protocols.models.AgentEndpoint voter, String targetStance, boolean support)	Submits a vote on a position.

Methods inherited from class com.tnsai.protocols.handlers.AbstractProtocolHandler

getTransport, isRunning, start, stop

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DebateProtocolHandler

public DebateProtocolHandler(Transport transport,
 int maxRounds,
 double consensusThreshold,
 com.tnsai.protocols.annotations.Debate.ConsensusStrategy strategy,
 long roundTimeoutMs)

Method Details

startDebate

public DebateProtocolHandler.DebateSession startDebate(String topic,
 com.tnsai.protocols.models.AgentEndpoint initiator,
 List<String> participants)
                                                throws ProtocolHandler.HandlerException

Starts a new debate.

Parameters:

topic - Debate topic

initiator - Agent starting the debate

participants - List of participating agent IDs

Returns:

DebateSession for tracking

Throws:

ProtocolHandler.HandlerException

submitPosition

public void submitPosition(String debateId,
 com.tnsai.protocols.models.AgentEndpoint sender,
 String stance,
 int confidence,
 String reasoning)
                    throws ProtocolHandler.HandlerException

Submits a position/opinion for the current round.

Parameters:

debateId - Debate session ID

sender - Agent submitting position

stance - The position being taken

confidence - Confidence level (1-10)

reasoning - Explanation for the position

Throws:

ProtocolHandler.HandlerException

vote

public void vote(String debateId,
 com.tnsai.protocols.models.AgentEndpoint voter,
 String targetStance,
 boolean support)
          throws ProtocolHandler.HandlerException

Submits a vote on a position.

Parameters:

debateId - Debate session ID

voter - Voting agent

targetStance - Stance being voted on

support - True for support, false for oppose

Throws:

ProtocolHandler.HandlerException

submitCounterArgument

public void submitCounterArgument(String debateId,
 com.tnsai.protocols.models.AgentEndpoint sender,
 String targetAgent,
 String counterArgument,
 String alternative)
                           throws ProtocolHandler.HandlerException

Submits a counter-argument.

Parameters:

debateId - Debate session ID

sender - Agent making counter-argument

targetAgent - Agent being countered

counterArgument - The counter-argument text

alternative - Optional alternative proposal

Throws:

ProtocolHandler.HandlerException

getDebate

public DebateProtocolHandler.DebateSession getDebate(String debateId)

Gets an active debate session.

getActiveDebates

public List<DebateProtocolHandler.DebateSession> getActiveDebates()

Gets all active debates.

send

public com.tnsai.protocols.models.Message send(com.tnsai.protocols.models.Message message)
                                        throws ProtocolHandler.HandlerException

Description copied from interface: ProtocolHandler

Sends a message using this protocol.

Parameters:

message - Message to send

Returns:

Response message (null for async protocols)

Throws:

ProtocolHandler.HandlerException - if send fails

sendAsync

public void sendAsync(com.tnsai.protocols.models.Message message,
 ProtocolHandler.HandlerCallback callback)

Description copied from interface: ProtocolHandler

Sends a message asynchronously.

Parameters:

message - Message to send

callback - Callback for response