11:59 a.m.
I also had an issue at one point where the agent detected new knowledge but it didn't
seem to load within the current knowledge base. I was able to fix it via the agent
config:
KnowledgeAgentConfiguration agentConfig =
KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
agentConfig.setProperty("drools.agent.newInstance",
"false");
KnowledgeAgent agent =
KnowledgeAgentFactory.newKnowledgeAgent("myagent", agentConfig);
-----Original Message-----
From: riri [mailto:irina.adam@gmail.com]
Sent: Wednesday, May 01, 2013 6:25 AM
To: rules-users(a)lists.jboss.org
Subject: Re: [rules-users] KnowledgeAgent to update knowledge base built with Guvnor pkg
Nobody has any ideas on how to solve this? I am willing to try anything that might work
short of re-creating the knowledge base everytime I start a new session.
And when using the changeSet() method for the knowledge agent, how would one set the
knowledge base properties? Like functioning in STREAM mode and not CLOUD.
Please, anyone, I really need your help.
--
View this message in context:
http://drools.46999.n3.nabble.com/KnowledgeAgent-to-update-knowledge-base...
Sent from the Drools: User forum mailing list archive at Nabble.com.
1:35 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
I already had this configured and still the changes were not detected. I am
really wondering if the knowledge agent can update a knowledge base built
with Guvnor urls when the agent uses a pre existing knowledge base. Maybe
it is just not possible or I am doing something very wrong in my code.
On Wed, May 1, 2013 at 6:59 PM, Roger Swanson <roger.swanson(a)issinc.com>wrote:
I also had an issue at one point where the agent detected new
knowledge
but it didn't seem to load within the current knowledge base. I was able
to fix it via the agent config:
KnowledgeAgentConfiguration agentConfig =
KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
agentConfig.setProperty("drools.agent.newInstance",
"false");
KnowledgeAgent agent =
KnowledgeAgentFactory.newKnowledgeAgent("myagent", agentConfig);
-----Original Message-----
From: riri [mailto:irina.adam@gmail.com]
Sent: Wednesday, May 01, 2013 6:25 AM
To: rules-users(a)lists.jboss.org
Subject: Re: [rules-users] KnowledgeAgent to update knowledge base built
with Guvnor pkg
Nobody has any ideas on how to solve this? I am willing to try anything
that might work short of re-creating the knowledge base everytime I start a
new session.
And when using the changeSet() method for the knowledge agent, how would
one set the knowledge base properties? Like functioning in STREAM mode and
not CLOUD.
Please, anyone, I really need your help.
--
View this message in context:
http://drools.46999.n3.nabble.com/KnowledgeAgent-to-update-knowledge-base...
Sent from the Drools: User forum mailing list archive at Nabble.com.
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
5:42 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
The KA should be able to update a knowledge base. Common errors include:
1) Not starting the ResourceChangeScanner and the ResourceChangeNotfier
(remember to stop them to prevent memory leaks)
2) An error in the changeset, pointing to non existing resources (check the
logs)
3) Loading resources with compile time errors (again, check the logs)
4) Not setting the "newInstance" flag, which will cause the KA to create a
new knowledge base rather than updating existing ones.
To provide more specific advice, it would be useful to see yours code.
There could always be a bug, but we'd need to confirm and reproduce it.
Best
Davide
On Wed, May 1, 2013 at 11:35 AM, Irina Adam <irina.adam(a)gmail.com> wrote:
I already had this configured and still the changes were not
detected. I
am really wondering if the knowledge agent can update a knowledge base
built with Guvnor urls when the agent uses a pre existing knowledge base.
Maybe it is just not possible or I am doing something very wrong in my code.
On Wed, May 1, 2013 at 6:59 PM, Roger Swanson <roger.swanson(a)issinc.com>wrote:
> I also had an issue at one point where the agent detected new knowledge
> but it didn't seem to load within the current knowledge base. I was able
> to fix it via the agent config:
>
> KnowledgeAgentConfiguration agentConfig =
> KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
> agentConfig.setProperty("drools.agent.newInstance",
"false");
> KnowledgeAgent agent =
> KnowledgeAgentFactory.newKnowledgeAgent("myagent", agentConfig);
>
>
> -----Original Message-----
> From: riri [mailto:irina.adam@gmail.com]
> Sent: Wednesday, May 01, 2013 6:25 AM
> To: rules-users(a)lists.jboss.org
> Subject: Re: [rules-users] KnowledgeAgent to update knowledge base built
> with Guvnor pkg
>
> Nobody has any ideas on how to solve this? I am willing to try anything
> that might work short of re-creating the knowledge base everytime I start a
> new session.
>
> And when using the changeSet() method for the knowledge agent, how would
> one set the knowledge base properties? Like functioning in STREAM mode and
> not CLOUD.
>
> Please, anyone, I really need your help.
>
>
>
> --
> View this message in context:
>
http://drools.46999.n3.nabble.com/KnowledgeAgent-to-update-knowledge-base...
> Sent from the Drools: User forum mailing list archive at Nabble.com.
>
>
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
3:52 a.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Here is the code I am using to create the knowledge base, knowledge agent and
to retrieve the resources:
public static KnowledgeBase createKnowledgeBase(List<DroolsResource>
resources,
EventProcessingOption eventProcessingOption)
{
KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
for (DroolsResource resource : resources)
{
logger.info("Resource: " + resource.getType() + ", path type="
+ resource.getPathType() + ", path=" + resource.getPath());
switch (resource.getPathType())
{
case CLASSPATH:
builder.add(ResourceFactory.newClassPathResource(resource.getPath()),
resource.getType());
break;
case FILE:
builder.add(ResourceFactory.newFileResource(resource.getPath()),
resource.getType());
break;
case URL:
UrlResource urlResource = (UrlResource) ResourceFactory
.newUrlResource(resource.getPath());
if (resource.getUsername() != null)
{
logger.info("Setting authentication for: " +
resource.getUsername());
urlResource.setBasicAuthentication("enabled");
urlResource.setUsername(resource.getUsername());
urlResource.setPassword(resource.getPassword());
}
builder.add(urlResource, resource.getType());
break;
default:
throw new IllegalArgumentException(
"Unable to build this resource path type.");
}
}
if (builder.hasErrors()) {
throw new RuntimeException(builder.getErrors().toString());
}
KnowledgeBaseConfiguration conf =
KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
// setting the STREAM option
conf.setOption(eventProcessingOption);
// modify the default identity compare mode to equality
conf.setOption(AssertBehaviorOption.EQUALITY);
KnowledgeBase knowledgeBase =
KnowledgeBaseFactory.newKnowledgeBase(conf);
knowledgeBase.addKnowledgePackages(builder.getKnowledgePackages());
return knowledgeBase;
}
public static KnowledgeAgent createKnowledgeAgent(String
knowledgeAgentName, KnowledgeBase knowledgeBase)
{
KnowledgeAgentConfiguration aconf =
KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
aconf.setProperty("drools.agent.newInstance", "false");
KnowledgeAgent kagent =
KnowledgeAgentFactory.newKnowledgeAgent(knowledgeAgentName, knowledgeBase,
aconf);
ResourceFactory.getResourceChangeScannerService().start();
ResourceFactory.getResourceChangeNotifierService().start();
return kagent;
}
public DroolsResource getGuvnorResource(User user)
{
String packageName = user.getUsername();
String guvnorBinaryResourceUrl =
"http://127.0.0.1:8080/guvnor/rest/packages/" + packageName +
"/binary";
return new DroolsResource(guvnorBinaryResourceUrl, ResourcePathType.URL,
ResourceType.PKG, credentials.getUserPrincipal().getName(),
credentials.getPassword());
}
Where the DroolsResource is a custom class to hold information about a
resource:
public class DroolsResource
{
private String path;
private ResourcePathType pathType;
private ResourceType type;
private String username = null;
private String password = null;
//getters, setters and constructors
}
To initialize the environement I just call the method to create the
knowledge base once I have the DroolsResource and then the method to create
the knowledge agent. Afterwards I create a statefull knowledge session using
the getKnowledgeBase() of the agent. Would the problem be the Guvnor url
that I am using? I used the rest version since it sais that it builds the
package automatically. Or the fact that the url is not in a change-set.xml
file?
When I run the session the first time (via the fireUntilHalt() in a separate
thread), rules get executed correctly and I call the halt() method to stop
it. If I then go and change a rule in the package and restart the session
then no changes are taken into account. Is the way I am executing the
sessions a problem? I do not want to recreate a new session every time since
I would have to reinsert all the facts, so I retrieve the session from the
knowledge base. I dispose of the session when the application is shut down.
I am new at this so I might be overlooking an important aspect.
Many thanks for all your help.
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
4:34 a.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
As an addition to my post earlier, there is an error in the loggs regarding
the change-set.xml:
ERROR ExtensibleXmlParser:666 - (null: 6, 119): cvc-elt.1 : Declaration of
element 'change-set' not found.
My change-set.xml file is as follows:
<?xml version="1.0" encoding="UTF-8"?
<change-set xmlns="http://drools.org/drools-5.0/change-set"
xmlns:xs="http://www.w3.org/2001/XMLSchema-instance"
xs:schemaLocation="http://drools.org/drools-5.0/change-set.xsd
http://anonsvn.jboss.org/repos/labs/labs/jbossrules/trunk/drools-api/src/...
<add <resource
source='classpath:ruleFiles/BasicWithFacts.drl'
type='DRL' / </add
</change-set
The resources are added correctly and there are no other errors however.
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
12:41 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Thanks, I'll try to reproduce it later. Just a couple of side notes..
Given that the rules fire correctly the first time, I would exclude that the
wrong URL is used. The ChangeScanner has a polling interval of **60**
seconds, so
changes may not be immediate. You can configure that interval, though.
In the logs, then, you should see something like :
"ResourceChangeScanner attempt to scan x resources"
(it's a DEBUG level message, you may want to configure log4j accordingly)
x obviously should be greater than 0.
You should then see a message saying that the ResourceChangeScanner
modified/removed/added some resources. If not, it's not picking up the
change..
I'd try forcing a PKG rebuild manually after changing the rules in guvnor.
The changeset.xsd error is just a warning, it won't affect execution.
On 05/02/2013 01:52 AM, riri wrote:
Here is the code I am using to create the knowledge base, knowledge
agent and
to retrieve the resources:
public static KnowledgeBase createKnowledgeBase(List<DroolsResource>
resources,
EventProcessingOption eventProcessingOption)
{
KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
for (DroolsResource resource : resources)
{
logger.info("Resource: " + resource.getType() + ", path type="
+ resource.getPathType() + ", path=" + resource.getPath());
switch (resource.getPathType())
{
case CLASSPATH:
builder.add(ResourceFactory.newClassPathResource(resource.getPath()),
resource.getType());
break;
case FILE:
builder.add(ResourceFactory.newFileResource(resource.getPath()),
resource.getType());
break;
case URL:
UrlResource urlResource = (UrlResource) ResourceFactory
.newUrlResource(resource.getPath());
if (resource.getUsername() != null)
{
logger.info("Setting authentication for: " +
resource.getUsername());
urlResource.setBasicAuthentication("enabled");
urlResource.setUsername(resource.getUsername());
urlResource.setPassword(resource.getPassword());
}
builder.add(urlResource, resource.getType());
break;
default:
throw new IllegalArgumentException(
"Unable to build this resource path type.");
}
}
if (builder.hasErrors()) {
throw new RuntimeException(builder.getErrors().toString());
}
KnowledgeBaseConfiguration conf =
KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
// setting the STREAM option
conf.setOption(eventProcessingOption);
// modify the default identity compare mode to equality
conf.setOption(AssertBehaviorOption.EQUALITY);
KnowledgeBase knowledgeBase =
KnowledgeBaseFactory.newKnowledgeBase(conf);
knowledgeBase.addKnowledgePackages(builder.getKnowledgePackages());
return knowledgeBase;
}
public static KnowledgeAgent createKnowledgeAgent(String
knowledgeAgentName, KnowledgeBase knowledgeBase)
{
KnowledgeAgentConfiguration aconf =
KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
aconf.setProperty("drools.agent.newInstance", "false");
KnowledgeAgent kagent =
KnowledgeAgentFactory.newKnowledgeAgent(knowledgeAgentName, knowledgeBase,
aconf);
ResourceFactory.getResourceChangeScannerService().start();
ResourceFactory.getResourceChangeNotifierService().start();
return kagent;
}
public DroolsResource getGuvnorResource(User user)
{
String packageName = user.getUsername();
String guvnorBinaryResourceUrl =
"http://127.0.0.1:8080/guvnor/rest/packages/" + packageName +
"/binary";
return new DroolsResource(guvnorBinaryResourceUrl, ResourcePathType.URL,
ResourceType.PKG, credentials.getUserPrincipal().getName(),
credentials.getPassword());
}
Where the DroolsResource is a custom class to hold information about a
resource:
public class DroolsResource
{
private String path;
private ResourcePathType pathType;
private ResourceType type;
private String username = null;
private String password = null;
//getters, setters and constructors
}
To initialize the environement I just call the method to create the
knowledge base once I have the DroolsResource and then the method to create
the knowledge agent. Afterwards I create a statefull knowledge session using
the getKnowledgeBase() of the agent. Would the problem be the Guvnor url
that I am using? I used the rest version since it sais that it builds the
package automatically. Or the fact that the url is not in a change-set.xml
file?
When I run the session the first time (via the fireUntilHalt() in a separate
thread), rules get executed correctly and I call the halt() method to stop
it. If I then go and change a rule in the package and restart the session
then no changes are taken into account. Is the way I am executing the
sessions a problem? I do not want to recreate a new session every time since
I would have to reinsert all the facts, so I retrieve the session from the
knowledge base. I dispose of the session when the application is shut down.
I am new at this so I might be overlooking an important aspect.
Many thanks for all your help.
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
2:33 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Thank you for the tips! I did change the scanning interval to 20s and I wait
before restarting the session. I have also tried to compile the package
manually in Guvnor after changing a rule but still no effect. The problem is
that I use the embedded editor in my application for creating a rule and so
normally the user would not have access to Guvnor to retrigger the build.
Programatically would that mean to use a builder to rebuild the packages but
then wouldn't I be creating a new knowledge base?
And also, what line should I include in the log4j config file to enable the
debug messages for Drools? Or should I just have the root logger set to
debug? At the moment I do not see the message at all.
I apologize if some of my questions are dumb, I'm still trying to get my
head around how everything works together.
Best regards
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
2:43 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
My fault, I just realized the KA is not using log4j. To enable the logs,
you should do:
// enable scanner and notifier logs before starting them :
SystemEventListenerFactory.setSystemEventListener(new
PrintStreamSystemEventListener());
// enable agent event logs just after creating it :
agent.addEventListener( new DebugKnowledgeAgentEventListener() );
these listeners will log to System.out and System.err.. if that doesn't
work for you,
you can reimplement their interfaces
the logs would be the knowledge agent's logs, so they would be
On 05/02/2013 12:33 PM, riri wrote:
Thank you for the tips! I did change the scanning interval to 20s and
I wait
before restarting the session. I have also tried to compile the package
manually in Guvnor after changing a rule but still no effect. The problem is
that I use the embedded editor in my application for creating a rule and so
normally the user would not have access to Guvnor to retrigger the build.
Programatically would that mean to use a builder to rebuild the packages but
then wouldn't I be creating a new knowledge base?
And also, what line should I include in the log4j config file to enable the
debug messages for Drools? Or should I just have the root logger set to
debug? At the moment I do not see the message at all.
I apologize if some of my questions are dumb, I'm still trying to get my
head around how everything works together.
Best regards
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
4:43 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Ok so I've added the listeners and I have run 2 scenarios:
1. I do not recreate the KA before I re-run a session, and all the info that
I get even after having deleted a rule from the package is :
// at the beginning
[2013-05-02 23:23:32,031:info] ResourceChangeNotification scanner has
started
[2013-05-02 23:23:32,032:debug] ResourceChangeScanner attempt to scan 2
resources
[2013-05-02 23:23:32,033:debug] ResourceChangeScanner thread is waiting for
60 seconds.
[2013-05-02 23:23:32,034:info] ResourceChangeNotification has started
listening for ChangeSet publications
[2013-05-02 23:23:32,034:debug] ResourceChangeNotification thread is waiting
for queue update
[2013-05-02 23:23:32,232:info] ResourceChangeScanner reconfigured with
interval=20
[2013-05-02 23:23:32,232:info] ResourceChangeScanner reconfigured with
interval=20
[2013-05-02 23:23:32,232:info] ResourceChangeNotification scanner has
stopped
[2013-05-02 23:23:32,233:info] ResourceChangeNotification scanner has
started
// after starting the services
[2013-05-02 23:23:32,233:debug] ResourceChangeScanner attempt to scan 2
resources
[2013-05-02 23:23:32,234:debug] ResourceChangeScanner thread is waiting for
20 seconds.
2. I re-create the KA before I run a session, and dispose of the previous
KA, and this is what I get without even making any changes to the rules (the
same messages stating that the services have started are present but not
included):
// after disposing of agent
[2013-05-02 23:23:50,466:debug] KnowledgeAgent unsubscribing from
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,466:debug] ResourceChangeNotification unsubscribing
listener=org.drools.agent.impl.KnowledgeAgentImpl@9a8636 to
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,467:debug] ResourceChangeScanner unsubcribing
notifier=org.drools.io.impl.ResourceChangeNotifierImpl@e171b2 to
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,467:debug] ResourceChangeScanner
resource=[ReaderResource resource=null encoding='null'] now has no
subscribers
[2013-05-02 23:23:50,467:debug] KnowledgeAgent unsubscribing from
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,467:debug] ResourceChangeNotification unsubscribing
listener=org.drools.agent.impl.KnowledgeAgentImpl@9a8636 to
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,467:debug] ResourceChangeScanner unsubcribing
notifier=org.drools.io.impl.ResourceChangeNotifierImpl@e171b2 to
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,467:debug] ResourceChangeScanner
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl'] now has no
subscribers
// after re creating the agent
[2013-05-02 23:23:50,698:debug] KnowledgeAgent building resource map
[2013-05-02 23:23:50,699:debug] KnowledgeAgent no resource mapped for
type=TypeDeclaration{typeName='StateEvent', role=FACT, format=POJO,
kind=CLASS, nature=DECLARATION}
[2013-05-02 23:23:50,699:debug] KnowledgeAgent mapping
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl'] to
KnowledgeDefinition=TypeDeclaration{typeName='StateEvent', role=FACT,
format=POJO, kind=CLASS, nature=DECLARATION}
[2013-05-02 23:23:50,699:debug] KnowledgeAgent notifier subscribing to
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,699:debug] ResourceChangeNotification subscribing
listener=org.drools.agent.impl.KnowledgeAgentImpl@1eaa99b to
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,698:info] KnowledgeAgent has started listening for
ChangeSet notifications
[2013-05-02 23:23:50,699:debug] ResourceChangeScanner subcribing
notifier=org.drools.io.impl.ResourceChangeNotifierImpl@e171b2 to
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl']
[2013-05-02 23:23:50,699:debug] KnowledgeAgent mapping
resource=[ClassPathResource path='ruleFiles/BasicWithFacts.drl'] to
KnowledgeDefinition=[Rule name=sensor has reading value, agendaGroup=MAIN,
salience=12, no-loop=true]
[2013-05-02 23:23:50,699:warning] KnowledgeAgent: impossible to add a map
for a null resource! skiping.
[2013-05-02 23:23:50,699:debug] KnowledgeAgent mapping
resource=[ReaderResource resource=null encoding='null'] to
KnowledgeDefinition=[Rule name=bla, agendaGroup=MAIN, salience=12,
no-loop=true]
[2013-05-02 23:23:50,699:debug] KnowledgeAgent notifier subscribing to
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,699:debug] ResourceChangeNotification subscribing
listener=org.drools.agent.impl.KnowledgeAgentImpl@1eaa99b to
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,699:debug] ResourceChangeScanner subcribing
notifier=org.drools.io.impl.ResourceChangeNotifierImpl@e171b2 to
resource=[ReaderResource resource=null encoding='null']
[2013-05-02 23:23:50,699:warning] KnowledgeAgent: impossible to add a map
for a null resource! skiping.
[2013-05-02 23:23:50,699:debug] KnowledgeAgent no resource mapped for
type=TypeDeclaration{typeName='StateEvent', role=FACT, format=POJO,
kind=CLASS, nature=DECLARATION}
[2013-05-02 23:23:50,699:warning] KnowledgeAgent: impossible to add a map
for a null resource! skiping.
[2013-05-02 23:23:50,699:info] KnowledgeAgent created, with configuration:
monitorChangeSetEvents=true scanResources=true scanDirectories=true
newInstance=false
[2013-05-02 23:23:50,700:info] ResourceChangeNotification scanner has
started
[2013-05-02 23:23:50,700:debug] ResourceChangeScanner attempt to scan 2
resources
[2013-05-02 23:23:50,700:debug] ResourceChangeScanner thread is waiting for
20 seconds.
From what I'm reading it seems that the Guvnor resource package is
null and
so there is nothing to subscribe to. I do not understand what I might be
doing wrong in this case or how to fix this since the rules are actually
included in the knowledge base.
Thank you very much for any help!
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
8:53 p.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Ok... I think I know what is happening..
Background: each element in a package (rule, process, function, etc..)
is mapped to the resource it was defined in. Resources can then be monitored
for changes and the KB will be updated as appropriate.
When the KnowledgeAgent (KA) is created with an initial KB,
it will not rebuild the mapping between elements and existing resources, but
"trust" the preexisting mapping and monitor the resources declared by
the KB.
The KA only builds the mapping itself when it's actively applying a
changest to
modify the KB it's managing.
This said, here's what's probably happening in your case:
You create a KB "manually" using the KnowledgeBuilder, which downloads
the serialized package from Guvnor. The elements in this package have been
created and mapped to the "internal" (guvnor-side) reader resource, not the
URLResource that Guvnor would expose the package at.
Of course this resource is not serializable, but is not replaced by Guvnor,
so the client gets a PKG whose elements are mapped to a "void" resource.
The KnowledgeBuilder does not override it - actually, it wouldn't
override it
even if it was NULL!.
Now, the KA won't either.. since 1) it trusts the preexisting mapping
in the KB and 2) it never sees the UrlResource in the first place.
In summary, when the KA tries to monitor an element's resource for changes,
it will try to use the void reader resource rather than the urlResrouce,
which explains why you don't get the desired updates.
The natural workaround is to initialize the KA with an empty KnowledgeBase.
Then, let the KA manage the resources by applying a changeset, as shown
in the documentation.
Best
Davide
IMHO, this behavior borderlines a bug. The KB on the client side is
essentially
corrupted, since rules, type declarations, etc.. are loaded with a "nulled"
resource. Currently, PackageBuilder.addPackageFromInputStream does not
override the resources in the PKG elements with the PKG itself.
I think I see the idea: if the PKG has been used for persistence, the
behavior
is correct. But here the PKG is used for distribution, so it should be
overridden.
Options are:
- always override
- always override if the PKG comes from a UrlResource (probably not robust)
- override if element.resource is null (likely to be impossible) OR
null-equivalent,
as in this case
- never override ( the current approach )
- other ideas?
On 05/02/2013 01:52 AM, riri wrote:
Here is the code I am using to create the knowledge base, knowledge
agent and
to retrieve the resources:
public static KnowledgeBase createKnowledgeBase(List<DroolsResource>
resources,
EventProcessingOption eventProcessingOption)
{
KnowledgeBuilder builder = KnowledgeBuilderFactory.newKnowledgeBuilder();
for (DroolsResource resource : resources)
{
logger.info("Resource: " + resource.getType() + ", path type="
+ resource.getPathType() + ", path=" + resource.getPath());
switch (resource.getPathType())
{
case CLASSPATH:
builder.add(ResourceFactory.newClassPathResource(resource.getPath()),
resource.getType());
break;
case FILE:
builder.add(ResourceFactory.newFileResource(resource.getPath()),
resource.getType());
break;
case URL:
UrlResource urlResource = (UrlResource) ResourceFactory
.newUrlResource(resource.getPath());
if (resource.getUsername() != null)
{
logger.info("Setting authentication for: " +
resource.getUsername());
urlResource.setBasicAuthentication("enabled");
urlResource.setUsername(resource.getUsername());
urlResource.setPassword(resource.getPassword());
}
builder.add(urlResource, resource.getType());
break;
default:
throw new IllegalArgumentException(
"Unable to build this resource path type.");
}
}
if (builder.hasErrors()) {
throw new RuntimeException(builder.getErrors().toString());
}
KnowledgeBaseConfiguration conf =
KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
// setting the STREAM option
conf.setOption(eventProcessingOption);
// modify the default identity compare mode to equality
conf.setOption(AssertBehaviorOption.EQUALITY);
KnowledgeBase knowledgeBase =
KnowledgeBaseFactory.newKnowledgeBase(conf);
knowledgeBase.addKnowledgePackages(builder.getKnowledgePackages());
return knowledgeBase;
}
public static KnowledgeAgent createKnowledgeAgent(String
knowledgeAgentName, KnowledgeBase knowledgeBase)
{
KnowledgeAgentConfiguration aconf =
KnowledgeAgentFactory.newKnowledgeAgentConfiguration();
aconf.setProperty("drools.agent.newInstance", "false");
KnowledgeAgent kagent =
KnowledgeAgentFactory.newKnowledgeAgent(knowledgeAgentName, knowledgeBase,
aconf);
ResourceFactory.getResourceChangeScannerService().start();
ResourceFactory.getResourceChangeNotifierService().start();
return kagent;
}
public DroolsResource getGuvnorResource(User user)
{
String packageName = user.getUsername();
String guvnorBinaryResourceUrl =
"http://127.0.0.1:8080/guvnor/rest/packages/" + packageName +
"/binary";
return new DroolsResource(guvnorBinaryResourceUrl, ResourcePathType.URL,
ResourceType.PKG, credentials.getUserPrincipal().getName(),
credentials.getPassword());
}
Where the DroolsResource is a custom class to hold information about a
resource:
public class DroolsResource
{
private String path;
private ResourcePathType pathType;
private ResourceType type;
private String username = null;
private String password = null;
//getters, setters and constructors
}
To initialize the environement I just call the method to create the
knowledge base once I have the DroolsResource and then the method to create
the knowledge agent. Afterwards I create a statefull knowledge session using
the getKnowledgeBase() of the agent. Would the problem be the Guvnor url
that I am using? I used the rest version since it sais that it builds the
package automatically. Or the fact that the url is not in a change-set.xml
file?
When I run the session the first time (via the fireUntilHalt() in a separate
thread), rules get executed correctly and I call the halt() method to stop
it. If I then go and change a rule in the package and restart the session
then no changes are taken into account. Is the way I am executing the
sessions a problem? I do not want to recreate a new session every time since
I would have to reinsert all the facts, so I retrieve the session from the
knowledge base. I dispose of the session when the application is shut down.
I am new at this so I might be overlooking an important aspect.
Many thanks for all your help.
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
2:54 a.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
Thank you very much for the detailed explanation, things are clearer now. I
would have liked to be able to initialize the KA with an empty KB but I need
to be able to set the configuration options for it and for now I don't see
how that is done. Can the options, like STREAM mode be set when creating the
KB from the KA?
Otherwise I will continue to re-create the environment before running a
session since for now it is the only option that works.
Best regards
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
3:01 a.m.
New subject: KnowledgeAgent to update knowledge base built with Guvnor pkg
The options are set at the KB level, way before rules etc.. are added.
So yes, you can initialize an empty KB and use changesets to add rules
dynamically later. Notice this:
KnowledgeBase knowledgeBase = KnowledgeBaseFactory.newKnowledgeBase(conf);
/* knowledgeBase.addKnowledgePackages(builder.getKnowledgePackages()); */
return knowledgeBase;
You can define a changeset in a file, or you can create it programmatically.
On 05/03/2013 12:54 AM, riri wrote:
Thank you very much for the detailed explanation, things are clearer
now. I
would have liked to be able to initialize the KA with an empty KB but I need
to be able to set the configuration options for it and for now I don't see
how that is done. Can the options, like STREAM mode be set when creating the
KB from the KA?
Otherwise I will continue to re-create the environment before running a
session since for now it is the only option that works.
Best regards
--
View this message in context:
http://drools.46999.n3.nabble.com/Re-rules-users-KnowledgeAgent-to-update...
Sent from the Drools: User forum mailing list archive at Nabble.com.
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
4255
days inactive
4257
days old
11 comments
4 participants
participants (4)
-
Davide Sottara -
Irina Adam -
riri
-
Roger Swanson