Muokkaa tiedostoa %ACTIVEMQ_BASE%/conf/activemq.xml, käyttäjätunnus ja salasana tallennetaan tiedostoon %ACTIVEMQ_BASE%/conf/credentials.properties,
activemq.xml tiedot ovat seuraavat:
<!-- Lisensoitu Apache Software Foundationille (ASF) yhdellä tai useammalla Avustajan lisenssisopimukset. Katso NOTICE-tiedosto, joka on jaettu Tämä teos tarjoaa lisätietoja tekijänoikeuden omistajuudesta. ASF lisensoi tämän tiedoston sinulle Apache-lisenssillä, versio 2.0 ("Lisenssi"); Et saa käyttää tätä tiedostoa muuten kuin vaatimusten mukaisesti Lisenssi. Voit hankkia lisenssin kopion osoitteesta
http://www.apache.org/licenses/LICENSE-2.0
Ellei sovellettava laki vaadi tai kirjallisesti sovittu, ohjelmisto jaetaan lisenssillä "AS ON"-PERIAATTEELLA, ILMAN MITÄÄN TAKUUTA TAI EHTOJA, joko nimenomaisia tai epäsuorasti. Katso lisenssistä erityiset käyttöoikeudet ja rajoitukset lisenssin nojalla. --> <!-- ALOITA SNIPPET: esimerkki --> <pavut xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">
<!-- Mahdollistaa järjestelmän ominaisuuksien käytön muuttujina tässä konfiguraatiotiedostossa --> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <value>file:${activemq.conf}/credentials.properties</value> </property> </bean>
<!-- Mahdollistaa lokin haun Hawtio-konsolissa --> <bean id="logQuery" class="org.fusesource.insight.log.log4j.Log4jLogQuery" lazy-init="väärä" scope="singleton" init-method="aloita" tuhoa-metodi="pysähdy"> </bean>
<!-- <broker> Elementtiä käytetään ActiveMQ-välittäjän konfigurointiin. --> <välittäjä xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true">
<destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" producerFlowControl="true" memoryLimit="1mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Ansioluettelo – > <policyEntry queue="PER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Enterprise - > <policyEntry queue="COM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Työmarkkinat – > <policyEntry queue="RECR.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Mikrorekrytointi --> <policyEntry queue="MCOM.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Mikrotyönhaku - > <policyEntry queue="MPER.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry>
<!-- Backend - > <policyEntry queue="ERP.>" producerFlowControl="true" memoryLimit="10mb"> <!-- VakioPendingMessageLimitStrategy käytetään estämään hidas aihe kuluttajat estävät tuottajia ja vaikuttavat muihin kuluttajiin rajoittamalla säilytettävien viestien määrää Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/slow-consumer-handling.html
--> <!-- Jakelustrategia – > <dispatchPolicy> <!-- Jaka peräkkäin - > <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- Toipumisstrategia – > <subscriptionRecoveryPolicy> <!-- Palauta vain viimeinen viesti --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> <pendingQueuePolicy> <!-- Ensin tallennetaan viestiviittaus muistiin, ja jos muistin käyttö on maksimissa, viestiviittaus tallennetaan väliaikaiseen tiedostoon --> <fileQueueCursor/> </pendingQueuePolicy> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="1000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy>
<!-- managementContext-tiedostoa käytetään konfiguroimaan ActiveMQ:n näkyvyyttä JMX. Oletuksena ActiveMQ käyttää MBean-palvelinta, joka käynnistyy JVM. Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/jmx.html --> <managementContext> <managementContext createConnector="false"/> </managementContext>
<!-- Määritä viestin pysyvyys välittäjälle. Oletuspysyvyys mekanismi on KahaDB-tallennus (tunnistettu KahaDB-tunnisteella). Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/persistence.html --> <persistenceAdapter> <kahaDB directory="E:/activemq_data" enableJournalDiskSyncs="false" indexWriteBatchSize="1000" indexCacheSize="10000" journalMaxFileLength="32mb"
/> </persistenceAdapter>
<plugins> <!-- Määritä tunnistautuminen; Käyttäjätunnus, salasanat ja ryhmät --> <simpleAuthenticationPlugin> <users> <authenticationUser username="${activemq.username}" password="${activemq.password}" groups="admins"/> <authenticationUser username="${per.username}" password="${per.password}" groups="personal"/> <authenticationUser username="${mper.username}" password="${mper.password}" groups="mpersonal"/> <authenticationUser username="${com.username}" password="${com.password}" groups="company"/> <authenticationUser username="${mcom.username}" password="${mcom.password}" groups="mcompany"/> <authenticationUser username="${erp.username}" password="${erp.password}" groups="erp"/> <authenticationUser username="${recr.username}" password="${recr.password}" groups="recr"/> </users> </simpleAuthenticationPlugin>
<!-- Konfiguroidaan kohdepohjainen valtuutusmekanismi --> <authorizationPlugin> <map> <authorizationMap> <authorizationEntries> <authorizationEntry queue=">" read="admins" write="admins" admin="admins" /> <authorizationEntry queue="PER.>" read="personal, mpersonal, company, mcompany, erp, recr" write="personal" admin="personal" /> <authorizationEntry queue="MPER.>" read="personal, mpersonal, company, mcompany, erp, recr" write="mpersonal" admin="mpersonal" /> <authorizationEntry queue="COM.>" read="henkilökohtainen, mpersonal, company, mcompany, erp, recr" write="company" admin="company" /> <authorizationEntry queue="MCOM.>" read="personal, mpersonal, company, mcompany, erp, recr" write="mcompany" admin="mcompany" /> <authorizationEntry queue="ERP.>" read="henkilökohtainen, mpersonal, company, mcompany, erp, recr" write="erp" admin="erp" /> <authorizationEntry queue="RECR.>" read="henkilökohtainen, mpersonal, company, mcompany, erp, recr" write="recr" admin="recr" />
<authorizationEntry topic="ActiveMQ.Advisory.>" read="personal, mpersonal, company, erp, recr" write="personal, mpersonal, company, mcompany, erp, recr" admin="personal, mpersonal, company, mcompany, erp, recr" /> </authorizationEntries> </authorizationMap> </map> </authorizationPlugin> </plugins>
<!-- systemUsage säätelee, kuinka paljon tilaa välittäjä saa Käytä ennen kuin poistat välimuistin käytöstä ja/tai hidastat tuottajia. Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/producer-flow-control.html --> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage percentOfJvmHeap="100" /> </memoryUsage> <storeUsage> <storeUsage limit="1 gb"/> </storeUsage> <tempUsage> <tempUsage limit="100 mb"/> </tempUsage> </systemUsage> </systemUsage>
<!-- Siirtoliittimet paljastavat ActiveMQ:n tietyn protokollan yli asiakkaita ja muita välittäjiä. Lisätietoja löytyy osoitteesta:
http://activemq.apache.org/configuring-transports.html --> <transportConnectors> <!-- DOS-suojaus, rajoita samanaikaiset yhteydet 1000 MB:iin ja kehyksen koko 100MB:iin --> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors>
<!-- tuhota kevätkonteksti pysäyttääkseen laiturin --> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks>
</broker>
<!-- Ota käyttöön web-konsolit, REST- ja Ajax-rajapinnat sekä demot Web-konsolit vaativat oletuksena kirjautumisen, voit poistaa sen käytöstä jetty.xml-tiedostossa
Katso lisätietoja ${ACTIVEMQ_HOME}/conf/jetty.xml --> <import resource="jetty.xml"/>
</beans> <!-- LOPPU SNIPPETTI: esimerkki -->
credentials.properties:
## --------------------------------------------------------------------------- ## Lisensoitu Apache Software Foundationille (ASF) yhdellä tai useammalla nimellä ## Avustajien lisenssisopimukset. Katso NOTICE-tiedosto, joka on jaettu ## tämä teos saadakseen lisätietoja tekijänoikeuden omistajuudesta. ## ASF lisensoi tämän tiedoston sinulle Apache-lisenssillä, versio 2.0 ## ("Lisenssi"); Et saa käyttää tätä tiedostoa muuten kuin vaatimusten mukaisesti ## Lisenssi. Voit hankkia lisenssin kopion osoitteesta ## ## http://www.apache.org/licenses/LICENSE-2.0 ## ## Ellei sovellettava laki vaadi tai kirjallisesti sovittu, ohjelmisto ## jaetaan lisenssillä "KUTEN ON"-periaatteella, ## ILMAN MITÄÄN TAKUITA TAI EHTOJA, joko nimenomaisia tai epäsuorasti. ## Katso lisenssi erityisestä kielestä, joka ohjaa käyttöoikeuksia ja ## rajoituksia lisenssin alla. ## ---------------------------------------------------------------------------
# Määrittelee tunnistetiedot, joita komponentit (kuten verkkokonsoli) käyttävät välittäjän käyttöön
activemq.username=*** activemq.password=***
per.username=*** per.password=***
mper.username=*** mper.password=***
com.username=*** com.password=***
mcom.username=*** mcom.password=***
erp.username=*** erp.password=***
recr.username=*** recr.password=***
Yllä oleva kokoonpano havaitsi tänään jonon valvonnassa poikkeavuuden, ja lopulta ongelma ilmeni tässä:
Koska jononvalvontaprojektin käyttäjätili on system/manager(webapps\admin\WEB-INF\webconsole-embedded.xml
Admins Group, joka vaatii käyttöoikeudet
|