ARTEMIS-904 Fixing server running
This commit is contained in:
parent
800976ec76
commit
92c84a1699
|
@ -17,6 +17,8 @@
|
||||||
package org.apache.activemq.artemis.cli;
|
package org.apache.activemq.artemis.cli;
|
||||||
|
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
|
import java.io.InputStream;
|
||||||
|
import java.io.OutputStream;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
import io.airlift.airline.Cli;
|
import io.airlift.airline.Cli;
|
||||||
|
@ -172,4 +174,18 @@ public class Artemis {
|
||||||
return builder;
|
return builder;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static void printBanner() throws Exception {
|
||||||
|
copy(Artemis.class.getResourceAsStream("banner.txt"), System.out);
|
||||||
|
}
|
||||||
|
|
||||||
|
private static long copy(InputStream in, OutputStream out) throws Exception {
|
||||||
|
byte[] buffer = new byte[1024];
|
||||||
|
int len = in.read(buffer);
|
||||||
|
while (len != -1) {
|
||||||
|
out.write(buffer, 0, len);
|
||||||
|
len = in.read(buffer);
|
||||||
|
}
|
||||||
|
return len;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,8 +22,8 @@ import java.util.TimerTask;
|
||||||
|
|
||||||
import io.airlift.airline.Command;
|
import io.airlift.airline.Command;
|
||||||
import io.airlift.airline.Option;
|
import io.airlift.airline.Option;
|
||||||
|
import org.apache.activemq.artemis.cli.Artemis;
|
||||||
import org.apache.activemq.artemis.cli.commands.tools.LockAbstract;
|
import org.apache.activemq.artemis.cli.commands.tools.LockAbstract;
|
||||||
import org.apache.activemq.artemis.cli.commands.tools.PrintData;
|
|
||||||
import org.apache.activemq.artemis.cli.factory.BrokerFactory;
|
import org.apache.activemq.artemis.cli.factory.BrokerFactory;
|
||||||
import org.apache.activemq.artemis.cli.factory.security.SecurityManagerFactory;
|
import org.apache.activemq.artemis.cli.factory.security.SecurityManagerFactory;
|
||||||
import org.apache.activemq.artemis.components.ExternalComponent;
|
import org.apache.activemq.artemis.components.ExternalComponent;
|
||||||
|
@ -60,7 +60,7 @@ public class Run extends LockAbstract {
|
||||||
public Object execute(ActionContext context) throws Exception {
|
public Object execute(ActionContext context) throws Exception {
|
||||||
super.execute(context);
|
super.execute(context);
|
||||||
|
|
||||||
PrintData.printBanner();
|
Artemis.printBanner();
|
||||||
|
|
||||||
BrokerDTO broker = getBrokerDTO();
|
BrokerDTO broker = getBrokerDTO();
|
||||||
|
|
||||||
|
|
|
@ -17,8 +17,6 @@
|
||||||
package org.apache.activemq.artemis.cli.commands.tools;
|
package org.apache.activemq.artemis.cli.commands.tools;
|
||||||
|
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
import java.io.InputStream;
|
|
||||||
import java.io.OutputStream;
|
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
@ -33,6 +31,7 @@ import io.airlift.airline.Command;
|
||||||
import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
|
import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
|
||||||
import org.apache.activemq.artemis.api.core.ActiveMQBuffers;
|
import org.apache.activemq.artemis.api.core.ActiveMQBuffers;
|
||||||
import org.apache.activemq.artemis.api.core.SimpleString;
|
import org.apache.activemq.artemis.api.core.SimpleString;
|
||||||
|
import org.apache.activemq.artemis.cli.Artemis;
|
||||||
import org.apache.activemq.artemis.cli.commands.ActionContext;
|
import org.apache.activemq.artemis.cli.commands.ActionContext;
|
||||||
import org.apache.activemq.artemis.core.journal.RecordInfo;
|
import org.apache.activemq.artemis.core.journal.RecordInfo;
|
||||||
import org.apache.activemq.artemis.core.message.impl.CoreMessagePersister;
|
import org.apache.activemq.artemis.core.message.impl.CoreMessagePersister;
|
||||||
|
@ -82,7 +81,7 @@ public class PrintData extends OptionalLocking {
|
||||||
public static void printData(File bindingsDirectory, File messagesDirectory, File pagingDirectory) throws Exception {
|
public static void printData(File bindingsDirectory, File messagesDirectory, File pagingDirectory) throws Exception {
|
||||||
// Having the version on the data report is an information very useful to understand what happened
|
// Having the version on the data report is an information very useful to understand what happened
|
||||||
// When debugging stuff
|
// When debugging stuff
|
||||||
printBanner();
|
Artemis.printBanner();
|
||||||
|
|
||||||
File serverLockFile = new File(messagesDirectory, "server.lock");
|
File serverLockFile = new File(messagesDirectory, "server.lock");
|
||||||
|
|
||||||
|
@ -136,20 +135,6 @@ public class PrintData extends OptionalLocking {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void printBanner() throws Exception {
|
|
||||||
copy(PrintData.class.getResourceAsStream("banner.txt"), System.out);
|
|
||||||
}
|
|
||||||
|
|
||||||
private static long copy(InputStream in, OutputStream out) throws Exception {
|
|
||||||
byte[] buffer = new byte[1024];
|
|
||||||
int len = in.read(buffer);
|
|
||||||
while (len != -1) {
|
|
||||||
out.write(buffer, 0, len);
|
|
||||||
len = in.read(buffer);
|
|
||||||
}
|
|
||||||
return len;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static void printPages(File pageDirectory, DescribeJournal describeJournal) {
|
private static void printPages(File pageDirectory, DescribeJournal describeJournal) {
|
||||||
try {
|
try {
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue