services.moleculer.repl

Class LocalRepl

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.Service

services.moleculer.repl.Repl

services.moleculer.repl.LocalRepl

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

RemoteRepl

public class LocalRepl
extends Repl
implements java.lang.Runnable

Local interactive console (uses System.in and System.out). To start console, type

 ServiceBroker broker = ServiceBroker.builder().build();
 broker.start();
 broker.repl();
 

Start telnet-based console:

 broker.repl(false);
 

See Also:

RemoteRepl

Field Summary

Fields

Modifier and Type	Field and Description
protected ColorWriter	colorWriter
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,Command>	commands
protected java.util.concurrent.ExecutorService	executor
protected java.lang.String	lastCommand
protected java.lang.String[]	packagesToScan Java package(s) where the custom (user-defined) commands are located.
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,Command>	postDefinedCommands
protected LocalReader	reader

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
LocalRepl()
LocalRepl(java.lang.String... packagesToScan)

Method Summary

Modifier and Type	Method and Description
void	addCommand(Command command)
java.lang.String[]	getPackagesToScan()
protected void	load(java.lang.String... commands)
void	onCommand(java.io.PrintWriter out, java.lang.String command)
protected java.lang.String[]	parseLine(java.lang.String command)
protected void	printCommandHelp(java.io.PrintWriter out, java.lang.String name)
protected void	printHelp(java.io.PrintWriter out, boolean telnet)
void	run()
void	setPackagesToScan(java.lang.String... packagesToScan)
protected void	showStartMessage()
void	started(services.moleculer.ServiceBroker broker) Initializes console instance.
protected void	startReading()
protected void	stopReading()

Methods inherited from class services.moleculer.repl.Repl

isEnabled, setEnabled, startOrStopReading, stopNow, stopped

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

packagesToScan

protected java.lang.String[] packagesToScan

Java package(s) where the custom (user-defined) commands are located.

commands

protected java.util.concurrent.ConcurrentHashMap<java.lang.String,Command> commands

postDefinedCommands

protected java.util.concurrent.ConcurrentHashMap<java.lang.String,Command> postDefinedCommands

executor

protected java.util.concurrent.ExecutorService executor

lastCommand

protected java.lang.String lastCommand

reader

protected LocalReader reader

colorWriter

protected ColorWriter colorWriter

Constructor Detail

LocalRepl

public LocalRepl()

LocalRepl

public LocalRepl(java.lang.String... packagesToScan)

Method Detail

started

public void started(services.moleculer.ServiceBroker broker)
             throws java.lang.Exception

Initializes console instance.

Overrides:

started in class Repl

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

startReading

protected void startReading()

Specified by:

startReading in class Repl

load

protected void load(java.lang.String... commands)

showStartMessage

protected void showStartMessage()

addCommand

public void addCommand(Command command)

run

public void run()

Specified by:

run in interface java.lang.Runnable

onCommand

public void onCommand(java.io.PrintWriter out,
                      java.lang.String command)
               throws java.lang.Exception

Specified by:

onCommand in class Repl

Throws:

java.lang.Exception

parseLine

protected java.lang.String[] parseLine(java.lang.String command)

printHelp

protected void printHelp(java.io.PrintWriter out,
                         boolean telnet)

printCommandHelp

protected void printCommandHelp(java.io.PrintWriter out,
                                java.lang.String name)

stopReading

protected void stopReading()

Specified by:

stopReading in class Repl

getPackagesToScan

public java.lang.String[] getPackagesToScan()

setPackagesToScan

public void setPackagesToScan(java.lang.String... packagesToScan)