[Geoserver-users] Issue on Notification community module Plugin

GeoServer GeoServer User
1

Hi All,
I’m using this community plugin for Notifications:
https://docs.geoserver.org/stable/en/user/community/notification/index.html#notification-community-module-plugin-documentation

I was able to make it work with RabbitMQ as fanout,
but I’m experiencing an issue just as I want messages to be sent to a topic on ActiveMQ.

This XML setting works well with RabbitMQ and sends a message to queue “changes” on “exchange1”

<notificator>
	<queueSize>1000</queueSize>
		<processorThreads>10</processorThreads>
		<messageFilter>type='Data'</messageFilter>
		<genericProcessor>
			<fanoutSender>
				<username>guest</username>
				<password>guest</password>
				<host>localhost</host>
				<port>5672</port>
				<virtualHost>/</virtualHost>
				<exchangeName>exchange1</exchangeName>
				<routingKey>changes</routingKey>
			</fanoutSender>
	</genericProcessor>
</notificator>


Instead for **Apache ActiveMQ** I'm trying to make geoserver send message to a topic named "topic.geoserver", so I replaced <fanoutSender> with <**topicSender**> and I filled others like this:

<notificator>
	<queueSize>1000</queueSize>
		<processorThreads>10</processorThreads>
		<messageFilter>type='Data'</messageFilter>
		<genericProcessor>
			<**topicSender**>
				<username>admin</username>
				<password>admin</password>
				<host>localhost</host>
				<port>5672</port>
				<virtualHost>/</virtualHost>
				<exchangeName>topic.geoserver</exchangeName>
				<routingKey>topic.geoserver</routingKey>
			</**topicSender**>
		</genericProcessor>
</notificator>


But it doesn't send message to AMQP server,

it raises an error as follows:

24 nov 11:41:15 ERROR [geoserver.notification] -
java.lang.NullPointerException
        at org.geoserver.notification.common.DefaultNotificationProcessor.process(DefaultNotificationProcessor.java:38)
        at org.geoserver.notification.MessageProcessor$WorkerThread.run(MessageProcessor.java:80)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)




Probably I'm not setting the XML in the correct way. Can you help me to solve this issue?

Thanx very much,

Regards,

Gianni