I''m trying to install mcollective on an environment for the first time
and
I''m having troubles:
MC client (also the puppet master)
activemq.xml
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance
with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:amq="http://activemq.apache.org/schema/core"
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-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">
<!-- Allows us to use system properties as variables in this
configuration file -->
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.base}/conf/credentials.properties</value>
</property>
</bean>
<!--
The <broker> element is used to configure the ActiveMQ broker.
-->
<broker xmlns="http://activemq.apache.org/schema/core"
brokerName="puppet.test.italy.cloudlabcsi.local"
dataDirectory="${activemq.base}/data" destr
oyApplicationContextOnStop="true">
<!--
For better performances use VM cursor and small memory limit.
For more information, see:
http://activemq.apache.org/message-cursors.html
Also, if your producer is "hanging", it''s probably
due to producer
flow control.
For more information, see:
http://activemq.apache.org/producer-flow-control.html
-->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">"
producerFlowControl="false"
memoryLimit="1mb">
<pendingSubscriberPolicy>
<vmCursor />
</pendingSubscriberPolicy>
</policyEntry>
<policyEntry queue="*.reply.>"
gcInactiveDestinations="true"
inactiveTimoutBeforeGC="300000">
<!--
Use VM cursor for better latency
For more information, see:
http://activemq.apache.org/message-cursors.html
<pendingQueuePolicy>
<vmQueueCursor/>
</pendingQueuePolicy>
-->
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<!--
The managementContext is used to configure how ActiveMQ is
exposed in
JMX. By default, ActiveMQ uses the MBean server that is started by
the JVM. For more information, see:
http://activemq.apache.org/jmx.html
-->
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<!--
Configure message persistence for the broker. The default
persistence
mechanism is the KahaDB store (identified by the kahaDB tag).
For more information, see:
http://activemq.apache.org/persistence.html
-->
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
<plugins>
<!--
Enable the statisticsBrokerPlugin to allow ActiveMQ to collect
statistics.
-->
<statisticsBrokerPlugin/>
<!--
Here we define a default set of users
-->
<simpleAuthenticationPlugin>
<users>
<authenticationUser username="admin"
password="secret"
groups="mcollective,admins,everyone"/>
<authenticationUser username="mcollective"
password="mcopwd"
groups="mcollective,admins,everyone"/>
</users>
</simpleAuthenticationPlugin>
<authorizationPlugin>
<map>
<authorizationMap>
<authorizationEntries>
<authorizationEntry queue=">"
write="admins"
read="admins" admin="admins" />
<authorizationEntry topic=">"
write="admins"
read="admins" admin="admins" />
<authorizationEntry topic="mcollective.>"
write="mcollective" read="mcollective"
admin="mcollective" />
<authorizationEntry queue="mcollective.>"
write="mcollective" read="mcollective"
admin="mcollective" />
<authorizationEntry
topic="ActiveMQ.Advisory.>"
read="everyone" write="everyone"
admin="everyone"/>
</authorizationEntries>
</authorizationMap>
</map>
</authorizationPlugin>
</plugins>
<!--
The systemUsage controls the maximum amount of space the broker
will
use before slowing down producers. For more information, see:
http://activemq.apache.org/producer-flow-control.html
-->
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="20 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="1 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="100 mb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<!--
The transport connectors expose ActiveMQ over a given protocol to
clients and other brokers. For more information, see:
http://activemq.apache.org/configuring-transports.html
-->
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616"/>
<transportConnector name="stomp+nio"
uri="stomp+nio://0.0.0.0:61613"/>
</transportConnectors>
</broker>
<!--
Enable web consoles, REST and Ajax APIs and demos
It also includes Camel (with its web console), see
${ACTIVEMQ_HOME}/conf/camel.xml for more info
Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details
-->
<import resource="jetty.xml"/>
</beans>
----------
client.cfg
main_collective = mcollective
collectives = mcollective
libdir = /usr/libexec/mcollective
logger_type = console
loglevel = debug
# Plugins
securityprovider = psk
plugin.psk = mcopwd
connector = activemq
direct_addressing = 1
plugin.activemq.pool.size = 1
plugin.activemq.pool.1.host = puppet.test.italy.cloudlabcsi.local
plugin.activemq.pool.1.port = 61613
plugin.activemq.pool.1.user = mcollective
plugin.activemq.pool.1.password = mcopwd
# Facts
factsource = yaml
plugin.yaml = /etc/mcollective/facts.yaml
and the result of mco ping
debug 2013/11/25 13:02:31: pluginmanager.rb:167:in `loadclass'' Loading
Mcollective::Facts::Yaml_facts from mcollective/facts/yaml_facts.rb
debug 2013/11/25 13:02:31: pluginmanager.rb:44:in `<<''
Registering plugin
facts_plugin with class MCollective::Facts::Yaml_facts single_instance: true
debug 2013/11/25 13:02:31: pluginmanager.rb:167:in `loadclass'' Loading
Mcollective::Connector::Activemq from mcollective/connector/activemq.rb
debug 2013/11/25 13:02:31: pluginmanager.rb:44:in `<<''
Registering plugin
connector_plugin with class MCollective::Connector::Activemq
single_instance: true
debug 2013/11/25 13:02:31: pluginmanager.rb:167:in `loadclass'' Loading
Mcollective::Security::Psk from mcollective/security/psk.rb
debug 2013/11/25 13:02:31: pluginmanager.rb:44:in `<<''
Registering plugin
security_plugin with class MCollective::Security::Psk single_instance: true
debug 2013/11/25 13:02:31: pluginmanager.rb:167:in `loadclass'' Loading
Mcollective::Registration::Agentlist from
mcollective/registration/agentlist.rb
debug 2013/11/25 13:02:31: pluginmanager.rb:44:in `<<''
Registering plugin
registration_plugin with class MCollective::Registration::Agentlist
single_instance: true
debug 2013/11/25 13:02:31: pluginmanager.rb:47:in `<<''
Registering plugin
global_stats with class MCollective::RunnerStats single_instance: true
info 2013/11/25 13:02:31: config.rb:141:in `loadconfig'' PLMC1: The
Marionette Collective version 2.3.2 started by /usr/bin/mco using config
file /etc/mcollective/client.cfg
debug 2013/11/25 13:02:31: pluginmanager.rb:167:in `loadclass'' Loading
MCollective::Application::Ping from mcollective/application/ping.rb
debug 2013/11/25 13:02:31: pluginmanager.rb:44:in `<<''
Registering plugin
ping_application with class MCollective::Application::Ping single_instance:
true
debug 2013/11/25 13:02:31: pluginmanager.rb:80:in `[]'' Returning new
plugin
ping_application with class MCollective::Application::Ping
debug 2013/11/25 13:02:31: pluginmanager.rb:80:in `[]'' Returning new
plugin
connector_plugin with class MCollective::Connector::Activemq
debug 2013/11/25 13:02:31: pluginmanager.rb:80:in `[]'' Returning new
plugin
security_plugin with class MCollective::Security::Psk
debug 2013/11/25 13:02:31: pluginmanager.rb:83:in `[]'' Returning cached
plugin global_stats with class MCollective::RunnerStats
debug 2013/11/25 13:02:31: activemq.rb:171:in `connect'' Adding
puppet.test.italy.cloudlabcsi.local:61613 to the connection pool
info 2013/11/25 13:02:31: activemq.rb:96:in `on_connecting'' TCP
Connection
attempt 0 to stomp://mcollective@puppet.test.italy.cloudlabcsi.local:61613
info 2013/11/25 13:02:31: activemq.rb:101:in `on_connected'' Conncted to
stomp://mcollective@puppet.test.italy.cloudlabcsi.local:61613
debug 2013/11/25 13:02:31: client.rb:146:in `req'' Publishing request to
agent discovery with timeout 5
debug 2013/11/25 13:02:31: pluginmanager.rb:83:in `[]'' Returning cached
plugin security_plugin with class MCollective::Security::Psk
debug 2013/11/25 13:02:31: base.rb:178:in `create_request'' Encoding a
request for agent ''discovery'' in collective mcollective with
request id
3a538b89ef035a379834b27ecdf6ce6e
debug 2013/11/25 13:02:31: psk.rb:98:in `callerid'' Setting callerid to
uid=0 based on callertype=uid
debug 2013/11/25 13:02:31: client.rb:51:in `sendreq'' Sending request
3a538b89ef035a379834b27ecdf6ce6e to the discovery agent with ttl 60 in
collective mcollective
debug 2013/11/25 13:02:31: client.rb:63:in `subscribe'' Subscribing to
reply
target for agent discovery
debug 2013/11/25 13:02:31: pluginmanager.rb:83:in `[]'' Returning cached
plugin connector_plugin with class MCollective::Connector::Activemq
debug 2013/11/25 13:02:31: activemq.rb:293:in `subscribe'' Subscribing
to
/queue/mcollective.reply.puppet_15959 with headers {}
debug 2013/11/25 13:02:31: pluginmanager.rb:83:in `[]'' Returning cached
plugin connector_plugin with class MCollective::Connector::Activemq
debug 2013/11/25 13:02:31: activemq.rb:282:in `publish'' Sending a
broadcast
message to ActiveMQ target
''/topic/mcollective.discovery.agent'' with
headers
''{"reply-to"=>"/queue/mcollective.reply.puppet_15959",
"timestamp"=>"1385380951000",
"expires"=>"1385381021000"}''
debug 2013/11/25 13:02:31: activemq.rb:249:in `receive'' Waiting for a
message from ActiveMQ
debug 2013/11/25 13:02:36: client.rb:73:in `unsubscribe'' Unsubscribing
reply target for discovery
debug 2013/11/25 13:02:36: pluginmanager.rb:83:in `[]'' Returning cached
plugin connector_plugin with class MCollective::Connector::Activemq
debug 2013/11/25 13:02:36: activemq.rb:305:in `unsubscribe''
Unsubscribing
from /queue/mcollective.reply.puppet_15959
---- ping statistics ----
No responses received
debug 2013/11/25 13:02:36: pluginmanager.rb:83:in `[]'' Returning cached
plugin connector_plugin with class MCollective::Connector::Activemq
debug 2013/11/25 13:02:36: activemq.rb:324:in `disconnect''
Disconnecting
from ActiveMQ
info 2013/11/25 13:02:36: activemq.rb:106:in `on_disconnect''
Disconnected
from stomp://mcollective@puppet.test.italy.cloudlabcsi.local:61613
On the mcollective server
server.cfg
# Basic stuff
registration_collective = mcollective
libdir = /usr/libexec/mcollective
logfile = /var/log/mcollective.log
loglevel = debug
daemonize = 1
main_collective = mcollective
collectives = mcollective
# Plugins
securityprovider = psk
plugin.psk = mcopwd
# Registration
#registerinterval = 300
#registration = Meta
# Middleware
connector = activemq
plugin.activemq.pool.1.host = puppet.test.italy.cloudlabcsi.local
plugin.activemq.pool.1.port = 61613
plugin.activemq.pool.1.user = mcollective
plugin.activemq.pool.1.password = mcopwd
plugin.activemq.pool.1.ssl = 0
# NRPE
#plugin.nrpe.conf_dir = /etc/nrpe.d
# Facts
factsource = yaml
plugin.yaml = /etc/mcollective/facts.yaml
logger_type = file
keeplogs = 5
max_log_size = 2097152
logfacility = user
------------------
The log
D, [2013-11-25T12:46:36.725721 #7697] DEBUG -- : pluginmanager.rb:167:in
`loadclass'' Loading Mcollective::Facts::Yaml_facts from
mcollective/facts
/yaml_facts.rb
D, [2013-11-25T12:46:36.760474 #7697] DEBUG -- : pluginmanager.rb:44:in
`<<'' Registering plugin facts_plugin with class
MCollective::Facts::Yaml_f
acts single_instance: true
D, [2013-11-25T12:46:36.760774 #7697] DEBUG -- : pluginmanager.rb:167:in
`loadclass'' Loading Mcollective::Connector::Activemq from
mcollective/con
nector/activemq.rb
D, [2013-11-25T12:46:36.763661 #7697] DEBUG -- : pluginmanager.rb:44:in
`<<'' Registering plugin connector_plugin with class
MCollective::Connector
::Activemq single_instance: true
D, [2013-11-25T12:46:36.764103 #7697] DEBUG -- : pluginmanager.rb:167:in
`loadclass'' Loading Mcollective::Security::Psk from
mcollective/security/
psk.rb
D, [2013-11-25T12:46:36.766577 #7697] DEBUG -- : pluginmanager.rb:44:in
`<<'' Registering plugin security_plugin with class
MCollective::Security::
Psk single_instance: true
D, [2013-11-25T12:46:36.767017 #7697] DEBUG -- : pluginmanager.rb:167:in
`loadclass'' Loading Mcollective::Registration::Agentlist from
mcollective
/registration/agentlist.rb
D, [2013-11-25T12:46:36.768384 #7697] DEBUG -- : pluginmanager.rb:44:in
`<<'' Registering plugin registration_plugin with class
MCollective::Regist
ration::Agentlist single_instance: true
D, [2013-11-25T12:46:36.769385 #7697] DEBUG -- : pluginmanager.rb:47:in
`<<'' Registering plugin global_stats with class
MCollective::RunnerStats s
ingle_instance: true
I, [2013-11-25T12:46:36.782790 #7697] INFO -- : config.rb:141:in
`loadconfig'' PLMC1: The Marionette Collective version 2.3.2 started by
/usr/sbin
/mcollectived using config file /etc/mcollective/server.cfg
I, [2013-11-25T12:46:36.783049 #7697] INFO -- : mcollectived:35 The
Marionette Collective 2.3.2 started logging at debug level
D, [2013-11-25T12:46:36.783298 #7697] DEBUG -- : mcollectived:38 Starting
in the background (true)
D, [2013-11-25T12:46:36.794315 #7700] DEBUG -- : pluginmanager.rb:83:in
`[]'' Returning cached plugin global_stats with class
MCollective::RunnerSt
ats
D, [2013-11-25T12:46:36.794803 #7700] DEBUG -- : pluginmanager.rb:80:in
`[]'' Returning new plugin security_plugin with class
MCollective::Security
::Psk
D, [2013-11-25T12:46:36.795312 #7700] DEBUG -- : pluginmanager.rb:83:in
`[]'' Returning cached plugin global_stats with class
MCollective::RunnerSt
ats
D, [2013-11-25T12:46:36.795782 #7700] DEBUG -- : pluginmanager.rb:80:in
`[]'' Returning new plugin connector_plugin with class
MCollective::Connect
or::Activemq
Any hint on the problem
Thanks
--
You received this message because you are subscribed to the Google Groups
"Puppet Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to puppet-users+unsubscribe@googlegroups.com.
To view this discussion on the web visit
https://groups.google.com/d/msgid/puppet-users/95c4f621-594d-414d-ac8d-04098d701df8%40googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.