本文整理汇总了Java中org.apache.activemq.artemis.core.server.JournalType类的典型用法代码示例。如果您正苦于以下问题：Java JournalType类的具体用法？Java JournalType怎么用？Java JournalType使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
JournalType类属于org.apache.activemq.artemis.core.server包，在下文中一共展示了JournalType类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: assertBrokerXmlContent
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
private static void assertBrokerXmlContent(Configuration cfg) {
assertNotNull(cfg);
Map<String, TransportConfiguration> connectors =
cfg.getConnectorConfigurations();
assertNotNull(connectors);
assertThat(connectors.size(), is(1));
assertNotNull(connectors.get("in-vm"));
Set<TransportConfiguration> acceptors = cfg.getAcceptorConfigurations();
assertNotNull(acceptors);
assertThat(acceptors.size(), is(1));
assertTrue(cfg.isPersistenceEnabled());
assertThat(cfg.getJournalType(), is(JournalType.NIO)); //(*)
}
开发者ID:openmicroscopy，项目名称:omero-ms-queue，代码行数:17，代码来源:CoreConfigFactoryTest.java
示例2: createConfiguration
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
public Configuration createConfiguration() {
ConfigurationImpl configuration = new ConfigurationImpl();
configuration.setSecurityEnabled(false);
configuration.setPersistenceEnabled(this.properties.isPersistent());
String dataDir = getDataDir();
configuration.setJournalDirectory(dataDir + "/journal");
if (this.properties.isPersistent()) {
configuration.setJournalType(JournalType.NIO);
configuration.setLargeMessagesDirectory(dataDir + "/largemessages");
configuration.setBindingsDirectory(dataDir + "/bindings");
configuration.setPagingDirectory(dataDir + "/paging");
}
TransportConfiguration transportConfiguration = new TransportConfiguration(
InVMAcceptorFactory.class.getName(),
this.properties.generateTransportParameters());
configuration.getAcceptorConfigurations().add(transportConfiguration);
if (this.properties.isDefaultClusterPassword()) {
logger.debug("Using default Artemis cluster password: "
+ this.properties.getClusterPassword());
}
configuration.setClusterPassword(this.properties.getClusterPassword());
return configuration;
}
开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:24，代码来源:ArtemisEmbeddedConfigurationFactory.java
示例3: createConfiguration
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
public Configuration createConfiguration() {
ConfigurationImpl configuration = new ConfigurationImpl();
configuration.setSecurityEnabled(false);
configuration.setPersistenceEnabled(this.properties.isPersistent());
String dataDir = getDataDir();
configuration.setJournalDirectory(dataDir + "/journal");
if (this.properties.isPersistent()) {
configuration.setJournalType(JournalType.NIO);
configuration.setLargeMessagesDirectory(dataDir + "/largemessages");
configuration.setBindingsDirectory(dataDir + "/bindings");
configuration.setPagingDirectory(dataDir + "/paging");
}
TransportConfiguration transportConfiguration = new TransportConfiguration(
InVMAcceptorFactory.class.getName(),
this.properties.generateTransportParameters());
configuration.getAcceptorConfigurations().add(transportConfiguration);
if (this.properties.isDefaultClusterPassword()) {
this.logger.debug("Using default Artemis cluster password: "
+ this.properties.getClusterPassword());
}
configuration.setClusterPassword(this.properties.getClusterPassword());
return configuration;
}
开发者ID:Nephilim84，项目名称:contestparser，代码行数:24，代码来源:ArtemisEmbeddedConfigurationFactory.java
示例4: JMSJournalStorageManagerImpl
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
public JMSJournalStorageManagerImpl(ExecutorFactory ioExecutors,
final IDGenerator idGenerator,
final Configuration config,
final ReplicationManager replicator) {
final EnumSet<JournalType> supportedJournalTypes = EnumSet.allOf(JournalType.class);
if (!supportedJournalTypes.contains(config.getJournalType())) {
throw new IllegalArgumentException("Only " + supportedJournalTypes + " are supported Journal types");
}
this.config = config;
createDir = config.isCreateBindingsDir();
SequentialFileFactory bindingsJMS = new NIOSequentialFileFactory(config.getBindingsLocation(), 1);
Journal localJMS = new JournalImpl(ioExecutors, 1024 * 1024, 2, config.getJournalPoolFiles(), config.getJournalCompactMinFiles(), config.getJournalCompactPercentage(), bindingsJMS, "activemq-jms", "jms", 1, 0);
if (replicator != null) {
jmsJournal = new ReplicatedJournal((byte) 2, localJMS, replicator);
} else {
jmsJournal = localJMS;
}
this.idGenerator = idGenerator;
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:26，代码来源:JMSJournalStorageManagerImpl.java
示例5: process
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
public void process(OutputStream out,
String bindingsDir,
String journalDir,
String pagingDir,
String largeMessagesDir) throws Exception {
config = new ConfigurationImpl().setBindingsDirectory(bindingsDir).setJournalDirectory(journalDir).setPagingDirectory(pagingDir).setLargeMessagesDirectory(largeMessagesDir).setJournalType(JournalType.NIO);
final ExecutorService executor = Executors.newFixedThreadPool(5, ActiveMQThreadFactory.defaultThreadFactory());
ExecutorFactory executorFactory = new OrderedExecutorFactory(executor);
storageManager = new JournalStorageManager(config, EmptyCriticalAnalyzer.getInstance(), executorFactory, executorFactory);
XMLOutputFactory factory = XMLOutputFactory.newInstance();
XMLStreamWriter rawXmlWriter = factory.createXMLStreamWriter(out, "UTF-8");
PrettyPrintHandler handler = new PrettyPrintHandler(rawXmlWriter);
xmlWriter = (XMLStreamWriter) Proxy.newProxyInstance(XMLStreamWriter.class.getClassLoader(), new Class[]{XMLStreamWriter.class}, handler);
writeXMLData();
executor.shutdown();
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:21，代码来源:XmlDataExporter.java
示例6: setUp
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Override
public void setUp() throws Exception {
super.setUp();
if (storage.equals("null")) {
server = createServer(false, true);
} else {
server = createServer(true, true);
}
jms = new JMSServerManagerImpl(server);
if (storage.equals("libaio")) {
server.getConfiguration().setJournalType(JournalType.ASYNCIO);
} else {
server.getConfiguration().setJournalType(JournalType.NIO);
}
jms.start();
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:21，代码来源:SyncSendTest.java
示例7: createConfig
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
protected Configuration createConfig(final String hostAddress, final int serverID, final int port) throws Exception {
ConfigurationImpl configuration = new ConfigurationImpl().setJMXManagementEnabled(false).
setSecurityEnabled(false).setJournalMinFiles(2).setJournalFileSize(1000 * 1024).setJournalType(JournalType.NIO).
setJournalDirectory(getJournalDir(serverID, false)).
setBindingsDirectory(getBindingsDir(serverID, false)).
setPagingDirectory(getPageDir(serverID, false)).
setLargeMessagesDirectory(getLargeMessagesDir(serverID, false)).
setJournalCompactMinFiles(0).
setJournalCompactPercentage(0).
setClusterPassword(CLUSTER_PASSWORD);
configuration.addAddressesSetting("#", new AddressSettings().setAutoCreateJmsQueues(true).setAutoDeleteJmsQueues(true));
configuration.addAcceptorConfiguration("netty", newURIwithPort(hostAddress, port));
configuration.addConnectorConfiguration("netty-connector", newURIwithPort(hostAddress, port));
return configuration;
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:OpenwireArtemisBaseTest.java
示例8: createConfig
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
protected Configuration createConfig(final String hostAddress, final int serverID) throws Exception {
ConfigurationImpl configuration = new ConfigurationImpl().setJMXManagementEnabled(false).
setSecurityEnabled(false).setJournalMinFiles(2).setJournalFileSize(1000 * 1024).setJournalType(JournalType.NIO).
setJournalDirectory(getJournalDir(serverID, false)).
setBindingsDirectory(getBindingsDir(serverID, false)).
setPagingDirectory(getPageDir(serverID, false)).
setLargeMessagesDirectory(getLargeMessagesDir(serverID, false)).
setJournalCompactMinFiles(0).
setJournalCompactPercentage(0).
setClusterPassword(CLUSTER_PASSWORD);
configuration.addAddressesSetting("#", new AddressSettings().setAutoCreateJmsQueues(true).setAutoDeleteJmsQueues(true));
configuration.addAcceptorConfiguration("netty", newURI(hostAddress, serverID));
configuration.addConnectorConfiguration("netty-connector", newURI(hostAddress, serverID));
return configuration;
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:19，代码来源:EmbeddedBrokerTestSupport.java
示例9: setupServer
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
private void setupServer(final JournalType journalType) throws Exception {
Configuration config = createDefaultNettyConfig().setJournalType(journalType).setJournalFileSize(ActiveMQDefaultConfiguration.getDefaultJournalFileSize()).setJournalMinFiles(ActiveMQDefaultConfiguration.getDefaultJournalMinFiles()).setJournalCompactMinFiles(2).setJournalCompactPercentage(50);
server = createServer(true, config);
server.start();
ServerLocator locator = createNettyNonHALocator().setBlockOnDurableSend(false).setBlockOnNonDurableSend(false).setBlockOnAcknowledge(false);
sf = createSessionFactory(locator);
ClientSession sess = sf.createSession();
try {
sess.createQueue(ADDRESS, QUEUE, true);
} catch (Exception ignored) {
}
sess.close();
locator.close();
locator = createInVMNonHALocator();
sf = createSessionFactory(locator);
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:24，代码来源:MultiThreadConsumerStressTest.java
示例10: persistenceEnablesAndSetsJournalType
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void persistenceEnablesAndSetsJournalType() {
JournalType journalType = JournalType.MAPPED;
Configuration actual = CoreConfigFactory.empty()
.with(persistence(journalType))
.apply(null);
assertTrue(actual.isPersistenceEnabled());
assertThat(actual.getJournalType(), is(journalType));
}
开发者ID:openmicroscopy，项目名称:omero-ms-queue，代码行数:10，代码来源:StoragePropsTest.java
示例11: defaultSettingsHaveNio
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void defaultSettingsHaveNio() {
Path dataDir = Paths.get("artemis-data");
Configuration actual =
CoreConfigFactory.empty()
.with(defaultStorageSettings(dataDir))
.apply(null);
assertThat(actual.getJournalType(), is(JournalType.NIO));
}
开发者ID:openmicroscopy，项目名称:omero-ms-queue，代码行数:10，代码来源:StoragePropsTest.java
示例12: persistenceSetup
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void persistenceSetup() {
ArtemisProperties properties = new ArtemisProperties();
properties.getEmbedded().setPersistent(true);
Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties)
.createConfiguration();
assertThat(configuration.isPersistenceEnabled()).isTrue();
assertThat(configuration.getJournalType()).isEqualTo(JournalType.NIO);
}
开发者ID:vikrammane23，项目名称:https-github.com-g0t4-jenkins2-course-spring-boot，代码行数:10，代码来源:ArtemisEmbeddedConfigurationFactoryTests.java
示例13: persistenceSetup
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void persistenceSetup() {
ArtemisProperties properties = new ArtemisProperties();
properties.getEmbedded().setPersistent(true);
Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties)
.createConfiguration();
assertThat(configuration.isPersistenceEnabled(), equalTo(true));
assertThat(configuration.getJournalType(), equalTo(JournalType.NIO));
}
开发者ID:Nephilim84，项目名称:contestparser，代码行数:10，代码来源:ArtemisEmbeddedConfigurationFactoryTests.java
示例14: configurePersistence
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
private void configurePersistence(Configuration cfg) {
cfg.setPersistenceEnabled(params.isPersistenceEnabled());
cfg.setJournalType(JournalType.NIO);
cfg.setJournalDirectory(params.getJournalDirPath());
cfg.setLargeMessagesDirectory(params.getLargeMessagesDirPath());
cfg.setBindingsDirectory(params.getBindingsDirPath());
cfg.setPagingDirectory(params.getPagingDirPath());
}
开发者ID:c0c0n3，项目名称:ome-smuggler，代码行数:9，代码来源:ArtemisServerCfgCustomizer.java
示例15: setupJournalType
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
private void setupJournalType() {
if (noJournalSync && !mapped) {
boolean useMapped = inputBoolean("--mapped", "Since you disabled syncs, it is recommended to use the Mapped Memory Journal. Do you want to use the Memory Mapped Journal", true);
if (useMapped) {
mapped = true;
nio = false;
aio = false;
}
}
int countJournalTypes = countBoolean(aio, nio, mapped);
if (countJournalTypes > 1) {
throw new RuntimeException("You can only select one journal type (--nio | --aio | --mapped).");
}
if (countJournalTypes == 0) {
if (supportsLibaio()) {
aio = true;
} else {
nio = true;
}
}
if (aio) {
journalType = JournalType.ASYNCIO;
} else if (nio) {
journalType = JournalType.NIO;
} else if (mapped) {
journalType = JournalType.MAPPED;
}
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:33，代码来源:Create.java
示例16: newFactory
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
private static SequentialFileFactory newFactory(File datafolder, boolean datasync, JournalType journalType, int fileSize, int maxAIO) {
SequentialFileFactory factory;
if (journalType == JournalType.ASYNCIO && !LibaioContext.isLoaded()) {
journalType = JournalType.NIO;
}
switch (journalType) {
case NIO:
factory = new NIOSequentialFileFactory(datafolder, 1).setDatasync(datasync);
((NIOSequentialFileFactory) factory).disableBufferReuse();
factory.start();
return factory;
case ASYNCIO:
factory = new AIOSequentialFileFactory(datafolder, maxAIO).setDatasync(datasync);
factory.start();
((AIOSequentialFileFactory) factory).disableBufferReuse();
return factory;
case MAPPED:
factory = new MappedSequentialFileFactory(datafolder, fileSize, false, 0, 0, null)
.setDatasync(datasync)
.disableBufferReuse();
factory.start();
return factory;
default:
throw ActiveMQMessageBundle.BUNDLE.invalidJournalType2(journalType);
}
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:30，代码来源:SyncCalculation.java
示例17: testSync
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void testSync() throws Exception {
int writes = 2;
int tries = 5;
long totalAvg = SyncCalculation.syncTest(temporaryFolder.getRoot(), 4096, writes, tries, true, true, true, "file.tmp", 1, JournalType.NIO);
System.out.println();
System.out.println("TotalAvg = " + totalAvg);
long nanoTime = SyncCalculation.toNanos(totalAvg, writes, false);
System.out.println("nanoTime avg = " + nanoTime);
assertEquals(0, LibaioContext.getTotalMaxIO());
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:13，代码来源:ArtemisTest.java
示例18: testValidateAIO
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Test
public void testValidateAIO() throws Exception {
Configuration config = createDefaultInVMConfig()
// This will force AsyncIO
.setJournalType(JournalType.ASYNCIO);
ActiveMQServer server = addServer(ActiveMQServers.newActiveMQServer(config, true));
try {
server.start();
} finally {
server.stop();
}
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:13，代码来源:ValidateAIOTest.java
示例19: extraServerConfig
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Override
protected void extraServerConfig(Configuration serverConfig) {
serverConfig.setJournalType(JournalType.NIO);
Map<String, AddressSettings> map = serverConfig.getAddressesSettings();
Map.Entry<String, AddressSettings> entry = map.entrySet().iterator().next();
AddressSettings settings = entry.getValue();
settings.setAutoCreateQueues(true);
System.out.println("server cofg, isauto? " + entry.getValue().isAutoCreateQueues());
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:10，代码来源:LargeMessageQueueAutoCreationTest.java
示例20: configureAddressPolicy
import org.apache.activemq.artemis.core.server.JournalType; //导入依赖的package包/类
@Override
protected void configureAddressPolicy(ActiveMQServer server) {
Configuration serverConfig = server.getConfiguration();
serverConfig.setJournalType(JournalType.NIO);
Map<String, AddressSettings> map = serverConfig.getAddressesSettings();
if (map.size() == 0) {
AddressSettings as = new AddressSettings();
map.put("#", as);
}
Map.Entry<String, AddressSettings> entry = map.entrySet().iterator().next();
AddressSettings settings = entry.getValue();
settings.setAutoCreateQueues(true);
System.out.println("server cofg, isauto? " + entry.getValue().isAutoCreateQueues());
}
开发者ID:apache，项目名称:activemq-artemis，代码行数:15，代码来源:QueueAutoCreationTest.java
注：本文中的org.apache.activemq.artemis.core.server.JournalType类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论