Hi Maria,
Is riak running? Can you verify it is running by using curl or wget?

    curl -v -X GET http://localhost:8090/riak

The errors says "connection refused" which tells me Riak is probably not 
running, or not running on the port you've specified (8090.)

If you can get Riak running and verify that you have Riak running (maybe try 
the Fast Track [1] to get started) then try the Java client code again.

Cheers

Russell

[1] Riak Fast Track - http://wiki.basho.com/The-Riak-Fast-Track.html

On 13 Jul 2011, at 17:42, Maria Neise wrote:

> Hey,
> I am writing an application with the Java-Api. In my application I try
> to get a connection to Riak using the RiakClient in order to insert
> some data. Before, I downloaded Riak with wget
> http://downloads.basho.com/riak/riak-0.14/riak_0.14.2-1_amd64.deb.
> When I start Riak with
> sudo riak start I always get attempting to restart script through sudo
> -u riak. When I start my application I get an RiakIORuntimeException,
> when trying to store a RiakObject. Here is my code:
> 
> public class RiakClient extends DB{
>       
>       com.basho.riak.client.http.RiakClient riakClient;
>       
>       public void init() throws DBException {
>               
>               try{
>                       
>                       riakClient = new
> com.basho.riak.client.http.RiakClient("http://localhost:8090/riak";);
>                       
>                       
>               } catch(Throwable t) {
>                       t.printStackTrace();
>               }
>       }
> 
> public int insert(String table, String key, HashMap<String, String> values) {
>               
>               try{
>                       
>                       com.basho.riak.client.http.RiakObject myObject = new
> com.basho.riak.client.http.RiakObject(table, key);
>                       
>                       Iterator it = values.entrySet().iterator();
>                       while(it.hasNext()){
>                               
>                               Map.Entry<String,String> pair = 
> (Map.Entry<String,String>)it.next();
>                               String entryKey = pair.getKey();
>                               String entryValue = pair.getValue();
>                               myObject.addUsermetaItem(entryKey, entryValue);
>                               
>                       }
>                       
>                       com.basho.riak.client.http.response.StoreResponse 
> storeResponse =
> riakClient.store(myObject);
>               
>                       if(!storeResponse.isSuccess()){
>                               return 1;
>                       }               
>               } catch(Throwable t) {
>                       t.printStackTrace();
>               }
>               
>               return 0;
>               
>       }
> 
> I also attached a screenshot from the Exception.
> 
> I would be grateful for any advice.
> Cheers,
> Maria
> <connection_refused.jpg>_______________________________________________
> riak-users mailing list
> riak-users@lists.basho.com
> http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

_______________________________________________
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com

Reply via email to